场景描述
在以下场景中,可以考虑查看Kafka的消费组列表:
- 监控消费组:通过查看消费组列表,可以监控和管理Kafka中的消费者。可以查看消费组的健康状态等信息,以确保消费者正常工作并及时发现潜在的问题。
- 动态调整消费者数量:通过查看消费组列表,可以了解当前的消费者数量和状态。根据实际需求,可以动态增加或减少消费者的数量,以适应不同的负载和流量变化。
操作步骤
(1)登录管理控制台。
(2)进入Kafka管理控制台。
(3)在实例列表页在操作列,目标实例行点击“管理”
(4)点击“消费组管理”后出现如下图列表
(5)右上角输入消费组名称,可查询对应消费组
消费组状态说明见下表:
状态 | 说明 |
---|---|
Empty | 消费组没有分配到任何分区进行消费。 |
PreparingRebalance | 消费组中有新的消费者加入或者有消费者离开,正在进行重新分配分区的准备工作。 |
CompletingRebalance | 1. 重新分配分区的过程已经完成,消费组即将开始消费。 |
Stable | 消费组中的消费者正常消费消息,并且消费进度与分区分配是一致的。 |
Dead | 消费组已经停止工作,没有任何活跃的消费者。 |
PreparingSync | 消费组正在准备同步消费进度,以确保消费者之间的一致性。 |
AwaitingSync | 消费组中的消费者正在等待同步消费进度的完成。 |
Rebalancing | 消费组正在进行重新分配分区的操作。 |
DeadAndEmpty | 消费组已经停止工作,且没有分配到任何分区进行消费。 |
消费实例
(1)登录管理控制台。
(2)进入Kafka管理控制台。
(3)在实例列表页在操作列,目标实例行点击“管理”。
(4)点击“消费组管理”后进入消费组管理页面。
(5)在目标消费组所在行,单击“更多 ”-“消费实例”。