查询消费组列表(控制台)

查询消费组列表(控制台)

前提条件

查询消费组列表(控制台)

步骤 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

相关推荐

自由不设线,潮流不重样:Beats Solo3 Wireless的深度测评报告
台湾十大网站排行 中国台湾最常用的网站 台湾门户网站有哪些→MAIGOO生活榜
盗墓长生印怎么刷钱 盗墓长生印赚钱攻略
365玩球安全吗

盗墓长生印怎么刷钱 盗墓长生印赚钱攻略

🗓️ 09-05 👁️ 2818
鹤归孤山斯人已至什么意思  鹤归孤山斯人已至的含义
365bet亚洲真人网址

鹤归孤山斯人已至什么意思 鹤归孤山斯人已至的含义

🗓️ 08-29 👁️ 9746
淘宝十大刷补单平台榜单?作者:小果 时间:2025-08-24 阅读:5609
学考乐怎么样?智能教育硬件使用体验报告
365体育app手机版下载

学考乐怎么样?智能教育硬件使用体验报告

🗓️ 08-04 👁️ 4963
️️顥的解释顥的意思康熙字典“顥”的释义
365bet亚洲真人网址

️️顥的解释顥的意思康熙字典“顥”的释义

🗓️ 08-02 👁️ 3148
Win10文件夹选项在哪
365体育app手机版下载

Win10文件夹选项在哪

🗓️ 07-24 👁️ 3618
WPS-C盘清理大师如何卸载
365体育app手机版下载

WPS-C盘清理大师如何卸载

🗓️ 07-11 👁️ 9581
java之路—— SpringMVC的常用注解解析以及作用、应用
365bet亚洲真人网址

java之路—— SpringMVC的常用注解解析以及作用、应用

🗓️ 07-21 👁️ 9277
川发龙蟒(002312) - 股东人数
365bet亚洲真人网址

川发龙蟒(002312) - 股东人数

🗓️ 10-17 👁️ 6049
研磨抛光中常见抛光皮的种类特性及应用解析
365bet亚洲真人网址

研磨抛光中常见抛光皮的种类特性及应用解析

🗓️ 07-24 👁️ 3942