刪除Topic
更新(xin)時間(jian) 2023-12-22 15:12:26
最近更新時間(jian): 2023-12-22 15:12:26
分享文章
本文主要介紹(shao) 刪除Topic。
本章節指(zhi)導(dao)您刪除Topic,請根據(ju)實際(ji)情況選(xuan)擇以下任(ren)意一(yi)種方(fang)式:
- 在控制臺刪除
- 在Kafka客戶端上刪除
前提條件
- 已創建Kafka實例,并且已創建Topic。
- 只有運行中的實例才可以刪除Topic。
在控制臺刪除
步驟 1 登錄管理(li)控制臺。
步驟 2 在管理控制臺右上角單擊
,選擇區域。
說明請選擇(ze)Kafka實例所在的區域。
步驟 3 在管理控制臺左上角單擊
,選擇“企業中間件”-“分布式(shi)消息服(fu)務(wu)”-“Kafka專享(xiang)版(ban)”,進入(ru)分布式(shi)消息服(fu)務(wu)Kafka專享(xiang)版(ban)頁面。
步驟 4 單擊Kafka實(shi)例(li)的名稱,進入(ru)實(shi)例(li)詳(xiang)情頁面。
步驟 5 選擇“Topic管理”頁(ye)簽,顯示已創建的(de)Topic詳情。
步驟 6 通過以(yi)下任意一種方法,刪除Topic。
- 勾選Topic名稱左側的方框,可選一個或多個,單擊信息欄左上側的“刪除Topic”。
- 在待刪除Topic所在行,單擊“更多 > 刪除”。
步(bu)驟 7 在“刪(shan)除Topic”對話框(kuang)中,單(dan)擊“是”,確認刪(shan)除Topic。
在Kafka客戶端上刪除
Kafka客戶端版本為2.2以上時,支持通過kafka-topics.sh刪除Topic。
- 未開啟SASL的Kafka實例,在“/{命令行工具所在目錄}/kafka_{version}/bin/”目錄下,通過以下命令刪除Topic。
./kafka-topics.sh --bootstrap-server {broker_ip}:{port} --delete --topic {topic_name}
- 已開啟SASL的Kafka實例,通過以下步驟刪除Topic。
- (可選)如果已經設置了SSL證書配置,請跳過此步驟。否則請執行以下操作。在Kafka客戶端的“/config”目錄中創建“ssl-user-config.properties”文件,參考步驟3增加SSL證書配置。
- 在“/{命令行工具所在目錄}/kafka_{version}/bin/”目錄下,通過以下命令刪除Topic。
./kafka-topics.sh --bootstrap-server {broker_ip}:{port} --delete --topic {topic_name} --command-config ./config/ssl-user-config.properties