Я могу проверить поддержку заголовка в Processor API, используя контекст процессора.Мне нужно выбрать потоки для отправки записей на основе заголовка.Как мы можем сделать то же самое в DSL?
Доступ к заголовкам (которые являются частью метаданных сообщения) невозможен через DSL напрямую.Как вы сказали, к ним можно получить доступ с помощью Processor API (начиная с версии 2.0).В настоящее время единственный способ получить доступ к заголовкам в DSL - это использовать методы DSL, такие как transform() или transformValues(), так что фактически используйте внутри них Processor API.KIP находится в стадии разработки для устранения этого недостатка: https://cwiki.apache.org/confluence/display/KAFKA/KIP-159%3A+Introducing+Rich+functions+to+Streams
transform()
transformValues()