kafka headers，在消费者

Question

我想使用 Kafka header 的功能。在制作事件时，我会设置 header。然后在消费时我会阅读 header 并根据 header 内容做出决定。

参见 KIP：https://cwiki.apache.org/confluence/display/KAFKA/KIP-82+-+Add+Record+Headers

我的问题是，我可以在没有 de-serializing 事件的情况下在消费者处阅读 header 吗？

谢谢。

Answer 1

据我所知这是不可能的。在协议级别，headers 是 FetchResponse 的 records_set 的一部分，它需要反序列化以及消息本身的有效负载。 从 Java 客户端 API 的角度来看，您无论如何都无法直接访问原始字节。