Храбрый след в Кафке Заголовки

Question

В SB2 Brave обрабатывает сообщения Kafka с заголовками B3 по умолчанию, однако мне нужно изменить вводимые имена полей. Например. X-B3-TraceId должен быть myEventTraceId. Есть простой способ сделать это? Даже некоторые рекомендации по дизайну очень помогли бы. Не возражаю против простого примера ... На ум приходят классы KafkaTracing и Injector. Спасибо.

Answer 1

Я закончил упаковывать возвращенный производитель в createProducer() моего пользовательского ProducerFactory в пользовательский класс делегата, который реализует Producer. Моя реализация send() была выполнена после TracingProducer.send() Brave, так что я мог изменить заголовки трассировки, установленные Brave в заголовки ProducerRecord до отправки битов. Та же логика применяется при потреблении.