前提條件
查詢消費組列表（控制臺）
步驟 1 登錄(lu)管理控制臺(tai)。
步驟 2 在管理控制臺右上角單擊
，選擇區域。
說明請選(xuan)擇Kafka實例所在的區域。
步驟 3 在管理控制臺左上角單擊
，選擇“企業中間(jian)件”-“分(fen)布式消息服務”-“Kafka專(zhuan)享版(ban)”，進入分(fen)布式消息服務Kafka專(zhuan)享版(ban)頁面。
步驟 4 單擊Kafka實例的名稱(cheng)，進入實例詳情頁面(mian)。
步驟(zou) 5 在(zai)左側(ce)導航(hang)欄(lan)選擇(ze)“消(xiao)費(fei)組管理”，進入(ru)消(xiao)費(fei)組列(lie)表頁面。
消費(fei)(fei)組(zu)列(lie)表頁面顯(xian)(xian)示(shi)消費(fei)(fei)組(zu)名稱、消費(fei)(fei)組(zu)狀態(tai)和Coordinator (ID)。Coordinator (ID)顯(xian)(xian)示(shi)的(de)(de)數(shu)字表示(shi)Coordinator組(zu)件所在(zai)的(de)(de)代理(li)，消費(fei)(fei)組(zu)的(de)(de)狀態(tai)如下。
- 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
查看消費者列表（控制臺）
步驟(zou) 1 登錄管(guan)理控制臺(tai)。
步驟 2 在管理控制臺右上角單擊
，選擇區域。
說明請選擇Kafka實例所在的區域。
步驟 3 在管理控制臺左上角單擊
，選擇“企業中間件”-“分(fen)布式消(xiao)(xiao)息(xi)服(fu)務”-“Kafka專享版”，進入分(fen)布式消(xiao)(xiao)息(xi)服(fu)務Kafka專享版頁面。
步驟 4 單擊Kafka實例的名稱，進入實例詳情頁面。
步驟 5 在左側導航欄(lan)選擇(ze)“消費組管理(li)”，進入消費組列表(biao)頁面(mian)。
步驟 6 單擊待查看消(xiao)費者列表(biao)的消(xiao)費組名稱，進入消(xiao)費組詳情頁。
步驟 7 在“消費(fei)者(zhe)列表”頁簽，查看(kan)消費(fei)者(zhe)列表。
在(zai)消(xiao)(xiao)費(fei)(fei)者(zhe)列表中，可以查看消(xiao)(xiao)費(fei)(fei)者(zhe)ID、消(xiao)(xiao)費(fei)(fei)者(zhe)地(di)址和客戶端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 登錄管理控制臺(tai)。
步驟 2 在管理控制臺右上角單擊
，選擇區域。
說明請選擇Kafka實例所在的區域。
步驟 3 在管理控制臺左上角單擊
，選(xuan)擇“企業中間(jian)件”-“分(fen)布(bu)式消息服務”-“Kafka專(zhuan)(zhuan)享版”，進(jin)入分(fen)布(bu)式消息服務Kafka專(zhuan)(zhuan)享版頁面(mian)。
步驟 4 單擊Kafka實例的名稱，進入實例詳(xiang)情頁面。
步驟 5 在左側導(dao)航欄選(xuan)擇(ze)“消(xiao)費組(zu)管理”，進入消(xiao)費組(zu)列表頁(ye)面(mian)。
步驟 6 單擊待查看消費進度的消費組(zu)名稱，進入消費組(zu)詳情(qing)頁。
步驟 7 在“消費(fei)進度”頁簽，查看此消費(fei)組(zu)訂閱的(de)Topic列表、Topic中消息(xi)的(de)總(zong)堆積數、Topic每(mei)個分(fen)區的(de)堆積數、Topic每(mei)個分(fen)區的(de)偏移(yi)量和最大消息(xi)位(wei)置。
圖 消費進度
步驟 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
