在sb2中，默认情况下，kafka消息带有b3头，但是我需要更改注入的字段名。e、 g.x-b3-traceid应该是myeventtraceid。有什么简单的方法吗？即使是一些设计指导也会大有帮助。我不介意举个简单的例子。。。Kafka塔林和注入器类出现在脑海中。谢谢。
pb3skfrl1#
最后我把制片人送了进来 createProducer() 我的习惯 ProducerFactory 在实现 Producer . 我的执行 send() 在勇士死后被处死 TracingProducer.send() 这样我就可以修改 ProducerRecord 发送位之前的头。同样的逻辑也适用于消费。
createProducer()
ProducerFactory
Producer
send()
TracingProducer.send()
ProducerRecord
1条答案
按热度按时间pb3skfrl1#
最后我把制片人送了进来
createProducer()我的习惯ProducerFactory在实现Producer. 我的执行send()在勇士死后被处死TracingProducer.send()这样我就可以修改ProducerRecord发送位之前的头。同样的逻辑也适用于消费。