spring - Brave Tracing in Kafka Headers

Question

In SB2, Brave instruments Kafka messages with B3 headers by default, however I need to change the field names that are injected. E.g. X-B3-TraceId should be myEventTraceId. Is there an easy way to do this? Even some design guidance would help greatly. Wouldnt mind a simple example... KafkaTracing and Injector classes come to mind. Thanks.

Answer 1

我最终将createProducer()我的自定义返回的生产者包装ProducerFactory在一个自定义委托类中，该类实现了Producer. 我的实现是send()在 Brave 之后执行的TracingProducer.send()，这样我就可以在ProducerRecord发送位之前修改 Brave 在标头中设置的跟踪标头。消费时也适用相同的逻辑。