重要注意事項(xiàng)：

1. 盡管 Spring Cloud Stream Binder 中存在 Kafka 的整合，然而Spring Kafka 和 Spring Cloud Stream Kafka 在處理數(shù)據(jù)生產(chǎn)和消費(fèi)是存在差異，因此不要混用

2. 當(dāng) Spring Cloud Stream 發(fā)送消息包含頭信息時(shí)， KafkaDeserializer 實(shí)現(xiàn)方法回調(diào)時(shí)不會予以處理

3. 通常業(yè)務(wù)邏輯可以使用 @StreamListener 來監(jiān)聽數(shù)據(jù)（主體、載體），如果是需要更多頭信息，需要 SubscribableChannel來實(shí)現(xiàn)

4. @StreamListener 與 SubscribableChannel 實(shí)現(xiàn)是存在差異的，以 Kafka 為例，SubscribableChannel 會觸發(fā) Kafka 自定義反序列化

5. 如果同一個(gè)應(yīng)用同時(shí)使用 @StreamListener 和SubscribableChannel 時(shí)，兩者會輪流處理

6. Spring Cloud Stream Kafka 是將對象序列化成 JSON，通過JSON 反序列化成對象（不經(jīng)過自定義 Kafka 序列化/反序列化實(shí)現(xiàn)）

?

總結(jié)

以上是生活随笔為你收集整理的Spring Cloud Stream 与 Kafka 整合的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。