是否有任何API可以只从Kafka获取元数据和头,而不下载正文

ct3nt3jp  于 2023-11-16  发布在  Apache
关注(0)|答案(1)|浏览(120)
  • 问题是:我需要在一些Kafka主题的消息中做一些分析。这些消息的有效负载/主体非常大。因此,在消费者中导致了大量的资源使用,只是为了下载消息并丢弃有效负载。这是Java的一个特殊问题。分析只需要头部和元数据(时间戳,分区等)
  • 问题是:有没有任何API只允许获取元数据和头信息?希望是Python或Java,但我甚至会考虑GO。
cgvd09ve

cgvd09ve1#

没有。头作为记录的一部分存储,因此必须使用记录的整个主体。客户端库没有区别,因为这是Kafka TCP网络规范的一部分。

相关问题