前提条件
查询消费组列表（控制台）
步骤 1 登录管理控制台。
步骤 2 在管理控制台右上角单击
，选择区域。
说明请选择Kafka实例所在的区域。
步骤 3 在管理控制台左上角单击
，选择“企业中间件”-“分布式消息服务”-“Kafka专享版”，进入分布式消息服务Kafka专享版页面。
步骤 4 单击Kafka实例的名称，进入实例详情页面。
步骤 5 在左侧导航栏选择“消费组管理”，进入消费组列表页面。
消费组列表页面显示消费组名称、消费组状态和Coordinator (ID)。Coordinator (ID)显示的数字表示Coordinator组件所在的代理，消费组的状态如下。
- DEAD：消费组内没有任何成员，且没有任何元数据。
- EMPTY：消费组内没有任何成员，存在元数据。
- PREPARING_REBALANCE：准备开启Rebalance。
- COMPLETING_REBALANCE：所有成员加入消费组。
- STABLE：消费组内成员可以正常消费。
图 消费组列表
步骤 6 （可选）如果需要查询某个消费组，在搜索框中，输入消费组名称，单击
。
步骤 7 （可选）如果需要刷新消费组列表，在右上角单击
。
查询消费组列表（Kafka客户端）
- 未开启SASL的Kafka实例，在“/{命令行工具所在目录}/kafka_{version}/bin/”目录下，通过以下命令查询消费组列表。
./kafka-consumer-groups.sh --bootstrap-server {broker_ip}:{port} --list
- 已开启SASL的Kafka实例，通过以下步骤查询消费组列表。
- （可选）如果已经设置了SSL证书配置，请跳过此步骤。否则请执行以下操作。在Kafka客户端的“/config”目录中创建“ssl-user-config.properties”文件，参考步骤3增加SSL证书配置。
- 在“/{命令行工具所在目录}/kafka_{version}/bin/”目录下，通过以下命令查询消费组列表。
./kafka-consumer-groups.sh --bootstrap-server {broker_ip}:{port} --list --command-config ./config/ssl-user-config.properties
查看消费者列表（控制台）
步骤 1 登录管理控制台。
步骤 2 在管理控制台右上角单击
，选择区域。
说明请选择Kafka实例所在的区域。
步骤 3 在管理控制台左上角单击
，选择“企业中间件”-“分布式消息服务”-“Kafka专享版”，进入分布式消息服务Kafka专享版页面。
步骤 4 单击Kafka实例的名称，进入实例详情页面。
步骤 5 在左侧导航栏选择“消费组管理”，进入消费组列表页面。
步骤 6 单击待查看消费者列表的消费组名称，进入消费组详情页。
步骤 7 在“消费者列表”页签，查看消费者列表。
在消费者列表中，可以查看消费者ID、消费者地址和客户端ID。
步骤 8 （可选）如果需要查询某个消费者，在搜索框中，输入消费者ID，单击
。
查看消费者列表（Kafka客户端）
- 未开启SASL的Kafka实例，在“/{命令行工具所在目录}/kafka_{version}/bin/”目录下，通过以下命令查询消费者列表。
./kafka-consumer-groups.sh --bootstrap-server {broker_ip}:{port} --group {group_name} --members --describe
- 已开启SASL的Kafka实例，通过以下步骤查询消费者列表。
- （可选）如果已经设置了SSL证书配置，请跳过此步骤。否则请执行以下操作。在Kafka客户端的“/config”目录中创建“ssl-user-config.properties”文件，参考步骤3增加SSL证书配置。
- 在“/{命令行工具所在目录}/kafka_{version}/bin/”目录下，通过以下命令查询消费者列表。
./kafka-consumer-groups.sh --bootstrap-server {broker_ip}:{port} --group {group_name} --members --describe --command-config ./config/ssl-user-config.properties
查看消费进度（控制台）
步骤 1 登录管理控制台。
步骤 2 在管理控制台右上角单击
，选择区域。
说明请选择Kafka实例所在的区域。
步骤 3 在管理控制台左上角单击
，选择“企业中间件”-“分布式消息服务”-“Kafka专享版”，进入分布式消息服务Kafka专享版页面。
步骤 4 单击Kafka实例的名称，进入实例详情页面。
步骤 5 在左侧导航栏选择“消费组管理”，进入消费组列表页面。
步骤 6 单击待查看消费进度的消费组名称，进入消费组详情页。
步骤 7 在“消费进度”页签，查看此消费组订阅的Topic列表、Topic中消息的总堆积数、Topic每个分区的堆积数、Topic每个分区的偏移量和最大消息位置。
图 消费进度
步骤 8 （可选）如果需要查询某个Topic的消费进度，在搜索框中，输入Topic名称，单击
。
查看消费进度（Kafka客户端）
- 未开启SASL的Kafka实例，在“/{命令行工具所在目录}/kafka_{version}/bin/”目录下，通过以下命令查询消费进度。
./kafka-consumer-groups.sh --bootstrap-server {broker_ip}:{port} --offsets --describe --all-groups
- 已开启SASL的Kafka实例，通过以下步骤查询消费进度。
- （可选）如果已经设置了SSL证书配置，请跳过此步骤。否则请执行以下操作。在Kafka客户端的“/config”目录中创建“ssl-user-config.properties”文件，参考步骤3增加SSL证书配置。
- 在“/{命令行工具所在目录}/kafka_{version}/bin/”目录下，通过以下命令查询消费进度。
./kafka-consumer-groups.sh --bootstrap-server {broker_ip}:{port} --offsets --describe --all-groups --command-config ./config/ssl-user-config.properties
