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

我们的微服务正在使用JDK 8，Spring Cloud Stream API和Spring Boot 1.5.2.RELEASE在Kafka Queue上生成消息。对于消费者API，我们使用的是Spring Kafka 1.1.2.RELEASE，特别是@KafkaListener。消息类型的应用程序JSONSpring Cloud Stream Producer在使用Spring Kafka Consumer时添加“垃圾”字符

我们注意到，消费者有附加到附近的“的contentType”，该消息的一些垃圾字符被如下所示：JunkCharsInConsumer

当使用香草的Apache卡夫卡客户端API 0.10.2.1与JDK 8，我们仍然在收到的消息中看到垃圾字符。

仅当我们使用Cloud Stream SINK时，我们才能检索到没有任何垃圾字符的邮件。

这是一个问题还是在生产者/消费者有一些设置，我们可能会错过？请告知是否需要更多详细信息。

感谢

2017-06-19 barsakus

集制片headerMode到raw。

headerMode

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

默认：embeddedHeaders。

2017-06-19 18:29:01

谢谢你的回应和细节，加里。只是你知道这并没有解决问题。因此，目前我们已经将消息中的响应转换为字节数组，并进行了字符比较，从我们知道在垃圾后清理的第一个字符中提取内容。下线的长期方法是在消费者中使用StreamListener – barsakus

您必须错误配置某些内容 - 我可以向您保证，原始的'headerMode'不会将这些标头添加到消息正文中。 –

回答