java - 如何从 spring cloud stream app starter 源生成的 kafka 消息中删除内容类型 header

Question

对于 twitter 源，如果我们使用 @StreamListener(接收器)以外的自定义 kafka 消费者，它会为每个 kafka 消息创建一个 30 位的 header 。@StreamListener 将消息正确发送到带注释的方法(无 header )。问题是每个来源的标题大小都不同。那么，由于我使用的是自定义 kafka 消费者，因此如何动态了解消息的 header 大小？或者如何删除每条消息的 header 。？

更新:-

请在下面找到使用 TCP 源时 kafka-console-consumer 中收到的消息。

�
  contentType"application/octet-stream"hello world

我只需要得到消息而已。在这种情况下， Hello World

Answer 1

您使用的是什么版本的 Kafka？我问的原因是从 0.11 开始的 Kafka 支持 native header ，你不会再有这个问题了。