@kafkaListener处理Spring Cloud添加的标头

Question

我已经通过Spring Boot实现了一个Kafka简单主题消费者，我想使用@KafkaListener注释来获取消息。到目前为止还不错，我对Kafka的方法很满意。我现在面临的问题是，我正在阅读的由第三方发送到这个主题的内容，我认为是由云流绑定生成的，并且有如下标题：ëë½ contentType“text/plain” originalContentType“application/json；charset=UTF-8”

在留言前。我在这里试图实现的是，我希望将有效负载提取为字符串，而不需要所有不需要的额外头。

有没有办法保持@KafkaListener方法？如何正确处理标题？

谢谢

斯特凡诺。

Answer 1

我认为重点在于headerMode的embeddedHeaders：https://docs.spring.io/spring-cloud-stream/docs/Elmhurst.SR1/reference/htmlsingle/#_producer_properties.我想知道您是否可以升级到最新的Spring Cloud Stream，以依赖Apache Kafka中的内置头功能。我的意思是在Spring的云流生产者那一边。或者考虑禁用在其中嵌入头文件。另一种选择可能是在消费者端使用@StreamListener，而不是@KafkaListener。