首页 文章

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

提问于
浏览 次
0

我们的微服务使用JDK 8，带有Spring Boot 1.5.2.RELEASE的Spring Cloud Stream API，用于在Kafka Queue上生成消息 . 对于Consumer API，我们使用Spring Kafka 1.1.2.RELEASE，特别是 @KafkaListener . 消息类型是应用程序json

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

当使用带有JDK 8的vanilla Apache Kafka Client API 0.10.2.1时，我们仍然会在收到的消息中看到垃圾字符 .

只有当我们使用Cloud Stream SINK 时，我们才能检索没有任何垃圾字符的消息 .

这是一个问题，还是 生产环境 者/消费者中有一些我们可能错过的设置？如果需要更多详细信息，请告知 .

谢谢

java spring kafka-consumer-api spring-cloud-stream spring-kafka

1 回答

  • 0

    将 生产环境 者 headerMode 设置为 raw .

    见the reference documentation .

    headerMode设置为raw时，禁用输出中的标头嵌入 . 仅对本身不支持邮件头并需要标头嵌入的邮件中间件有效 . 在为非Spring Cloud Stream应用程序生成数据时很有用 . 默认值：embeddedHeaders .

    回复于

相关问题