我使用的春季卡夫卡消費者包裹在春季啓動應用程序中,並在關鍵雲代工廠部署爲微服務。我正在部署15個應用程序的實例,其中包括15個kafka分區。由於這些實例中的大多數會逐個啓動,會有多次重新平衡嗎?在雲中部署kafka用戶的推薦方式是什麼?雲中的卡夫卡消費者
0
A
回答
1
新的0.11客戶端有一個新的屬性group.initial.rebalance.delay.ms
see Notable changes in 0.11.0.0。
引入了一個新配置
group.initial.rebalance.delay.ms
。此配置指定以毫秒爲單位的時間,即GroupCoordinator
將延遲初始消費者重新平衡。當新成員加入該組時,重新平衡將進一步延遲group.initial.rebalance.delay.ms
的值,最多可達max.poll.interval.ms
。這個的默認值是3秒。在開發和測試期間,可能希望將其設置爲0,以便不延遲測試執行時間。
我們正在爲0.11客戶端添加支持。目前計劃用於Apache Kafka發佈的2.0 Spring,但我們正在考慮1.3版本的2.0功能的子集,並支持0.11。
你可以嘗試使用新的客戶端與較舊的春季卡夫卡;它可能工作,但當然,你不會得到0.11的功能,如交易和Headers
。
相關問題
- 1. 卡夫卡gruop消費者
- 2. Spark Streaming中的卡夫卡消費者
- 3. 卡夫卡消費者/生產者API
- 4. 如何從生產者消費卡夫卡的消費者?
- 5. 卡夫卡10.2新消費者與舊消費者
- 6. 復位消費者在卡夫卡0.10
- 7. 卡夫卡消費者查詢
- 8. 如何暫停卡夫卡消費者?
- 9. 卡夫卡消費者不是從
- 10. 卡夫卡消費者滯後JMX
- 11. 卡夫卡消費者行爲
- 12. 問題在消費者卡夫卡
- 13. 暫停高級卡夫卡消費者
- 14. 無法創建卡夫卡消費者
- 15. 卡夫卡消費者 - Java客戶端
- 16. 卡夫卡0.90消費者堅持
- 17. 卡夫卡消費者與JAVA
- 18. 春季集成卡夫卡消費者
- 19. 卡夫卡:消費者崩潰
- 20. 卡夫卡消費者沒有消費數據
- 21. 卡夫卡消費者中的控制消息偏移量
- 22. 卡夫卡消費10節
- 23. 卡夫卡消費者無法從卡夫卡的主題訂閱
- 24. 使用生產者消費者的卡夫卡和微服務
- 25. 在卡夫卡消費活的消息
- 26. 卡夫卡斯卡拉消費者代碼 - 打印消費記錄
- 27. 春天卡夫卡不支持大消息的消費者
- 28. 簡單的卡夫卡消費者消息傳遞重複
- 29. 消費者沒有從卡夫卡消費者提交的消息10消費者
- 30. 阿帕奇卡夫卡消費者花費很長時間
我認爲可行的另一個選擇是讓所有偵聽器容器在一開始就停下來,然後在雲中發生某些事件後立即執行所有偵聽器容器的啓動。通過Spring Cloud Bus –