当消费客户端出现Rebalance时,您可以查看Rebalance的详情,包括Rebalance的时间、耗时、次数、原因以及是否有新成员加入。

背景信息

Rebalance是消息队列Kafka版对分区和Consumer Group之间的消费对应关系进行重分配的过程。消费客户端出现Rebalance可能是以下原因:
  • 当消费者主动新增订阅或者取消订阅时,会触发该Consumer Group内的Rebalance。
  • 当Topic的分区数量发生变化时,会触发Rebalance。
  • 当Consumer Group内的消费者成员数量增加或者减少时,会触发Rebalacne。
    • 消费出现卡顿,导致消费者心跳超时,触发Rebalance来筛选不健康的消费者。
    • 消费时间过慢,超过一定时间(max.poll.interval.ms设置的值,默认5分钟)未进行Pull拉取消息,则会导致客户端主动离开队列,触发Rebalance。
    • 消费者数量过多,为避免当前Topic-Partition的任务浪费,需要关闭一定数量的消费者,触发Rebalance。
    • 消费者数量不足,当前Topic-Partition的任务出现延迟,需要增加一定数量的消费者,触发Rebalance。

操作步骤

  1. 登录消息队列Kafka版控制台,在左侧导航栏,单击实例列表
  2. 在顶部菜单栏,选择地域,然后在实例列表页面单击目标实例名称。
  3. 在左侧导航栏,单击Group 管理,然后单击目标Group名称。
  4. Group详情页面,单击Rebalance 详情页签。

后续步骤

当客户端频繁出现Rebalance时,您可以参考以下文档解决此问题:使用消息队列Kafka版时消费客户端频繁出现Rebalance