заголовки кафки, у потребителя

Question

Я хотел бы использовать функцию заголовков Kafka. При создании событий я бы установил заголовок. Затем по потреблению я бы прочитал заголовок и принял решение на основе содержимого этого заголовка.

См. KIP: https://cwiki.apache.org/confluence/display/KAFKA/KIP-82+-+Add+Record+Headers

У меня вопрос, могу ли я прочитать заголовок у потребителя без десериализации события?

Спасибо.

Answer 1

Насколько я знаю, это невозможно. На уровне протокола заголовки являются частью набора записей FetchResponse, и их необходимо десериализовать, а также полезную нагрузку самого сообщения. С точки зрения Java Client API в любом случае у вас нет способа получить прямой доступ к необработанным байтам.