朱迪
朱迪
## 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...
kq: 支持 kafka.Writer BatchTimeout/BatchBytes 配置 - 新增 WithBatchTimeout 选项,支持配置批量发送超时时间 - 新增 WithBatchBytes 选项,支持配置批量发送字节大小 - 补充完整的单元测试,覆盖单个配置和组合配置场景 涉及文件: - kq/pusher.go: 添加两个配置选项和对应的 PushOption 函数 - kq/pusher_test.go: 添加对应的单元测试用例 Greptile Overview Updated On: 2025-11-10 06:45:25...