分布式(shi)消息(xi)服務(wu)Kafka支持(chi)通過以(yi)下(xia)兩種(zhong)方式(shi)刪除消費組,您可以(yi)根(gen)據實際(ji)情況選擇任意一種(zhong)方式(shi)。
- 方法一:在管理控制臺刪除消費組
- 方法二:在使用命令行工具刪除消費組(確保Kafka實例版本與命令行工具版本相同)
前提條件
待刪除(chu)消(xiao)費(fei)組的狀態(tai)為“EMPTY”。
方法一:在管理控制臺刪除消費組
步驟 1 登錄管理控制臺(tai)。
步驟 2 在管理控制臺右上角單擊
,選擇區域。
說明請選擇Kafka實例所在的區域。
步驟 3 在管理控制臺左上角單擊
,選擇“企業(ye)中間件”-“分布式消(xiao)息(xi)服務”-“Kafka專(zhuan)享版(ban)”,進入分布式消(xiao)息(xi)服務Kafka專(zhuan)享版(ban)頁面。
步驟 4 單擊Kafka實例的名稱(cheng),進入(ru)實例詳情(qing)頁(ye)面。
步(bu)驟 5 在左側導(dao)航欄選擇“消費(fei)(fei)組(zu)管理(li)”,進入(ru)消費(fei)(fei)組(zu)列表頁面(mian)。
步驟 6 通(tong)過(guo)以下任意一種方(fang)法(fa),刪(shan)除消費組。
- 勾選消費組名稱左側的方框,可選一個或多個,單擊信息欄左上側的“刪除消費組”。
- 在待刪除消費組所在行,單擊“刪除”。
說明僅在“消費(fei)組狀態”為(wei)“EMPTY”時,支持刪(shan)除(chu)。
消費組包含以下狀態(tai):
- DEAD:消費組內沒有任何成員,且沒有任何元數據。
- EMPTY:消費組內沒有任何成員,存在元數據。
- PREPARING_REBALANCE:準備開啟Rebalance。
- COMPLETING_REBALANCE:所有成員加入消費組。
- STABLE:消費組內成員可以正常消費。
步驟(zou) 7 彈出“刪除消(xiao)費(fei)組”對話(hua)框,單擊“是(shi)”,完成消(xiao)費(fei)組的刪除。
方法二:使用命令行工具刪除消費組
以(yi)下操作命(ming)令以(yi)Linux系統為例進行說(shuo)明:
步驟 1 下(xia)載或者(zhe)(zhe)或者(zhe)(zhe),確(que)保Kafka實(shi)例版本與命(ming)令行工具版本相同。
步驟 2 使用命令行工具連接Kafka實例,具體步驟請參考連接未開啟SASL的Kafka實例或連接已開啟SASL的Kafka實例。
步驟 3 在(zai)“/{命令(ling)行工具所在(zai)目錄(lu)(lu)}/kafka_{version}/bin/”目錄(lu)(lu)下,執行以下命令(ling)刪除消費(fei)組。
./kafka-consumer-groups.sh --bootstrap-server {kafka連接地址} --delete --group {消費組}
[root@zk-server-1 bin]# ./kafka-consumer-groups.sh --bootstrap-server 192.168.1.245:9091,192.168.1.86:9091,192.168.1.128:9091 --delete --group bbbb
Note: This will not show information about old Zookeeper-based consumers.
Deletion of requested consumer groups ('bbbb') was successful.
說明如果Kafka實例開啟SASL認證,則以上命令還需要增加SASL認證的“consumer.properties”配置文件參數: --command-configSASL認證的consumer.properties配置文件}* ,“consumer.properties”配置文件參考連接已開啟SASL的Kafka實例。