在spring-cloud-stream kafka绑定器中接受二进制json消息的属性是什么

Question

我正在使用spring-cloud-stream kafka绑定器来消费来自kafka主题的消息。源系统正在以ascii发送json消息。当我的消费者听到它抛出的主题时

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

我可以在.yml文件中设置什么属性来反序列化它吗？或者有没有我可以研究的例子？

Answer 1

我不确定你所说的json in hexadecimal-binary data是什么意思如果你的意思是byte[]中的ascii数据，试着添加spring.cloud.stream.bindings.input.content-type=text/plain (或application/json)。

Answer 2

您可以在以下位置查找配置属性：http://docs.spring.io/spring-cloud-stream/docs/Brooklyn.SR2/reference/htmlsingle/#_kafka_consumer_properties

在您的示例中，您可以通过执行以下操作来设置此设置：

spring.cloud.stream.kafka.bindings.<channelName>.consumer.configuration.value.deserializer=<Deserialzier class>

Kafka绑定器从配置映射中获取所有属性。因此，您可以使用任何通用的Kafka消费者属性，并以这种方式传递它们。

Answer 3

当我添加content-type:plain/text和spring.cloud.stream.bindings.<subscriptionChannel>.consumer.‌​headerMode:raw时，它起作用了。

谢谢!