非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，它只會工作。 –

回答