2 个回答
kafka Topic 的分区在以下情况下会触发消费者再平衡操作:
1、新的消费者加入消费组。
2、当前消费者从消费组退出(不管是异常退出还是正常关闭)。
3、消费者取消对某个 Topic 的订阅。
4、订阅 Topic 的分区数发生变化。
5、broker宕机新的Coordinator当选。
6、当消费者在${session.timeout.ms}时间内还没有发送心跳请求,组协调器认为消费者已退出.
发布于:3个月前 (01-24) IP属地:四川省
以下情况下会触发再平衡
1、分区数发生变更(仅支持添加分区)
2、消费者组中的消费者数发生变更(例如:新的消费者加入或者退出,当前的消费者发生超时)
发布于:3个月前 (01-24) IP属地:四川省
我来回答
您需要 登录 后回答此问题!