kafka标头，在使用者处

Question

我想利用Kafka标头功能。产生事件时，我将设置标题。然后在消耗时，我将读取标题并根据该标题内容做出决定。

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

我的问题是，我可以在不对事件进行反序列化的情况下读取使用者的标头吗？

谢谢。

Answer 1

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