查看Rebalance详情

Rebalance是云消息队列 Kafka 版对分区和Consumer Group之间的消费对应关系进行重分配的过程。消费客户端出现Rebalance可能是以下原因：

• 当消费者主动新增订阅或者取消订阅时，会触发该Consumer Group内的Rebalance。

• 当Topic的分区数量发生变化时，会触发Rebalance。

• 当Consumer Group内的消费者成员数量增加或者减少时，会触发Rebalance。

  • 消费出现卡顿，导致消费者心跳超时，触发Rebalance来筛选不健康的消费者。

  • 消费时间过慢，超过一定时间（max.poll.interval.ms设置的值，默认5分钟）未进行Pull拉取消息，则会导致客户端主动离开队列，触发Rebalance。

  • 消费者数量过多，为避免当前Topic-Partition的任务浪费，需要关闭一定数量的消费者，触发Rebalance。

  • 消费者数量不足，当前Topic-Partition的任务出现延迟，需要增加一定数量的消费者，触发Rebalance。