spring-cloud-stream-kafka活页夹中接受二进制json消息的属性是什么 [英] what is the property to accept binary json message in spring-cloud-stream kafka binder

问题描述

我正在使用spring-cloud-stream kafka活页夹来使用来自kafka主题的消息.源系统正在以ascii发送json消息.当我的消费者收听主题时，它会引发

I am using spring-cloud-stream kafka binder to consume messages from a kafka topic. The source system is sending the json message in ascii. When My consumer listens to the topic it throws

o.s.c.s.b.k.KafkaMessageChannelBinder    : Could not convert message: 7B22736..

.yml文件中是否可以设置任何属性以反序列化它?还是有一个我可以研究的例子?

Is there any property that I can set in my .yml file to deserialize it? or is there an example that I can look into?

推荐答案

当我添加 content-type:plain/text 和 spring.cloud.stream.bindings.< subscriptionChannel>.consumer.‌headerMode:raw 正常工作.

谢谢！

这篇关于spring-cloud-stream-kafka活页夹中接受二进制json消息的属性是什么的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！