如何从spring cloud stream app启动源生成的kafka消息中删除内容类型标头

对于twitter源,如果我们使用除@StreamListener(Sink)之外的自定义kafka使用者,它将为每个kafka消息创建一个30位的头.
@StreamListener将消息正确地发送到带注释的方法(无标题).问题是每个源头的大小都有所不同.
那么我怎么能动态地理解消息的头大小,因为我使用的是自定义kafka消费者.
或者如何删除每封邮件的标题.

更新： –

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

�
  contentType"application/octet-stream"hello world

我只需要收到消息.在这种情况下,你好世界

解决方法:

你用的是什么版本的Kafka？我之所以要问的是,启动0.11 Kafka支持本机标头,你不会再遇到这个问题了.

标签：java,spring,spring-boot-2,spring-cloud-stream
来源： https://codeday.me/bug/20190627/1305568.html