分布式消息服务Kafka

消费组列表

2024-05-08 07:41:09

场景描述

在以下场景中,可以考虑查看Kafka的消费组列表:

l  监控消费组:通过查看消费组列表,可以监控和管理Kafka中的消费者。可以查看消费组的健康状态等信息,以确保消费者正常工作并及时发现潜在的问题。

l  动态调整消费者数量:通过查看消费组列表,可以了解当前的消费者数量和状态。根据实际需求,可以动态增加或减少消费者的数量,以适应不同的负载和流量变化。

操作步骤

(1)登录管理控制台。

(2)进入Kafka管理控制台。

(3)在实例列表页在操作列,目标实例行点击“管理”。

(4)点击“消费组管理”后出现如下图列表

(5)右上角输入消费组名称,可查询对应消费组

消费组状态说明见下表:

状态

说明

Empty

消费组没有分配到任何分区进行消费。

PreparingRebalance

消费组中有新的消费者加入或者有消费者离开,正在进行重新分配分区的准备工作。

CompletingRebalance

1.       重新分配分区的过程已经完成,消费组即将开始消费。

 

 

Stable

消费组中的消费者正常消费消息,并且消费进度与分区分配是一致的。

Dead

消费组已经停止工作,没有任何活跃的消费者。

PreparingSync

消费组正在准备同步消费进度,以确保消费者之间的一致性。

AwaitingSync

消费组中的消费者正在等待同步消费进度的完成。

Rebalancing

消费组正在进行重新分配分区的操作。

DeadAndEmpty

消费组已经停止工作,且没有分配到任何分区进行消费。

消费实例

(1)登录管理控制台。

(2)进入Kafka管理控制台。

(3)在实例列表页在操作列,目标实例行点击“管理”。

(4)点击“消费组管理”后进入消费组管理页面。

(5)在目标消费组所在行,单击“更多 ”-“消费实例”。

BX16dgqf93jZ