go-queue icon indicating copy to clipboard operation
go-queue copied to clipboard

feat: kq commitinorder support trace

Open zhuud opened this issue 1 year ago • 0 comments

Greptile Summary

Added OpenTelemetry tracing support to Kafka queue implementation, enabling distributed tracing across message processing with standardized context propagation.

  • Added kq/internal/trace.go implementing MessageCarrier interface for OpenTelemetry context handling
  • Added trace context injection in PushWithKey method using OpenTelemetry propagator
  • Added trace context extraction in extractCtxFromMsg function for consistent tracing
  • Enhanced error handling with context-aware logging in consumeOne method
  • Updated dependencies in go.mod to support OpenTelemetry integration

💡 (1/5) You can manually trigger the bot by mentioning @greptileai in a comment!

zhuud avatar Aug 27 '24 10:08 zhuud