Я пытаюсь добавить распределенную трассировку к своим работам Flink с помощью OpenTracing Brave API, я использую kafka в качестве источника и приемника для своих работ, могу ли я каким-то образом использовать перехватчики Kafka для добавления / чтения дорожки и идентификатора диапазона в / из Заголовки сообщений кафки и логировать их соответственно?