當前位置:
首頁 >
前端技术
> javascript
>内容正文
javascript
Spring Cloud Stream 与 Kafka 整合
生活随笔
收集整理的這篇文章主要介紹了
Spring Cloud Stream 与 Kafka 整合
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
重要注意事項:
1. 盡管 Spring Cloud Stream Binder 中存在 Kafka 的整合,然而Spring Kafka 和 Spring Cloud Stream Kafka 在處理數據生產和消費是存在差異,因此不要混用
2. 當 Spring Cloud Stream 發送消息包含頭信息時, KafkaDeserializer 實現方法回調時不會予以處理
3. 通常業務邏輯可以使用 @StreamListener 來監聽數據(主體、載體),如果是需要更多頭信息,需要 SubscribableChannel來實現
4. @StreamListener 與 SubscribableChannel 實現是存在差異的,以 Kafka 為例,SubscribableChannel 會觸發 Kafka 自定義反序列化
5. 如果同一個應用同時使用 @StreamListener 和SubscribableChannel 時,兩者會輪流處理
6. Spring Cloud Stream Kafka 是將對象序列化成 JSON,通過JSON 反序列化成對象(不經過自定義 Kafka 序列化/反序列化實現)
?
總結
以上是生活随笔為你收集整理的Spring Cloud Stream 与 Kafka 整合的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: Java趋势点评
- 下一篇: 微服务与Spring-Cloud的关系(