Kafka 中的勇敢追踪 Headers

Question

在 SB2 中，Brave 默认使用 B3 headers 检测 Kafka 消息，但是我需要更改注入的字段名称。例如。 X-B3-TraceId 应该是 myEventTraceId。是否有捷径可寻？即使是一些设计指导也会有很大帮助。不介意一个简单的例子……想到 KafkaTracing 和 Injector 类。谢谢

Answer 1

我最终将自定义 ProducerFactory 的 createProducer() 中返回的生产者包装在实现 Producer 的自定义委托 class 中。我的 send() 实现在 Brave 的 TracingProducer.send() 之后执行，这样我就可以在发送位之前修改 ProducerRecord headers 中的跟踪 headers Brave 集。同样的逻辑也适用于消费。