非Spring云流（SCS）生产者发送JSON消息给SCS消费者

我有一个非SCS生产者（使用Spring-Kafka的应用程序）试图将一个json序列化对象发送给SCS消费者订阅的主题。非Spring云流（SCS）生产者发送JSON消息给SCS消费者

提上话题的信息是 -

{ “消息”： “你好world2”， “移动电话号码”： “111111”}

的SCS消费者有以下配置。

spring.cloud.stream.bindings.input.content型=应用/ JSON spring.cloud.stream.bindings.input.consumer.headerMode =原始

该文件说SCS支持接收和发送有效载荷给非SCS生产者和消费者。有人能帮我弄清楚这里可能是错的吗？

2017-02-09 Ajay

我得到了SCS消费者通过改变配置来上班 - spring.cloud.stream.bindings.input.content型= text/plain的

2017-02-09 16:39:24 Ajay

有人能解释，为什么该消息最终为一个字符串连尽管在Spring-Kafka生产者端指定了JSONSerializer？ – Ajay

谢谢 - 两天试图弄清楚这一点。这不是很直观。你会想，如果发送和接收原始内容类型是应用程序/ JSON，它只会工作。 –

回答