Spring Cloud Stream Producer在使用Spring Kafka Consumer时添加了“垃圾”字符

Question

我们的微服务使用JDK 8、Spring Cloud Stream API和Spring Boot 1.5.2。用于在Kafka队列上生成消息的释放。对于消费者API，我们使用Spring Kafka 1.1.2。发布，特别是@KafkaListener。消息类型是应用程序json

我们注意到，消费者在“contentType”附近的消息中添加了一些垃圾字符，如下所示：JunkCharsInCustomer

在JDK 8中使用vanilla Apache Kafka客户端API 0.10.2.1时，我们仍然会在收到的消息中看到垃圾字符。

只有当我们使用Cloud StreamSINK时，我们才能在没有任何垃圾字符的情况下检索消息。

这是一个问题，还是我们可能错过了生产商/消费者的某些背景？如需更多详细信息，请告知。

谢谢

Answer 1

将生产者headerMode设置为raw。

请参见参考留档。

标题模式

当设置为raw时，禁用输出上的标题嵌入。仅对本机不支持消息头且需要嵌入消息头的消息传递中间件有效。在为非Spring云流应用程序生成数据时非常有用。

默认值：embeddedHeaders。