【思考?】什么时候会触发这个策略呢?
生活随笔
收集整理的這篇文章主要介紹了
【思考?】什么时候会触发这个策略呢?
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
當出現以下幾種情況時,kafka會進行一次分區分配操作,也就是kafka consumer的rebalance
1. 同一個consumer group內新增了消費者
2. 消費者離開當前所屬的consumer group,比如主動停機或者宕機
3. topic新增了分區(也就是分區數量發生了變化)
kafka consuemr的rebalance機制規定了一個consumer group下的所有consumer如何達成一致來分配訂閱topic的每個分區。而具體如何執行分區策略,就是前面提到過的兩種內置的分區策略。而kafka對于分配策略這塊,提供了可插拔的實現方式, 也就是說,除了這兩種之外,我們還可以創建自己的分配機制。
?
總結
以上是生活随笔為你收集整理的【思考?】什么时候会触发这个策略呢?的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: consumer和partition的数
- 下一篇: 什么是分区分配策略