1. 程式人生 > >kafka 刪除topic

kafka 刪除topic

兩種方法:

 

一、修改配置檔案server.properties

    新增如下配置:

        delete.topic.enable=true

 

說明:官方給的文件說明“Enables delete topic. Delete topic through the admin tool will have no effect if this config is turned off”,意思就是說如果想刪除topic,此項配置必須為true,預設為false。配置完重啟kafka、zookeeper。

 

二、如果不想修改配置,也可以徹底刪除topic

 

1、刪除kafka儲存目錄(server.propertiewenjian log.dirs配置,預設為“/tmp/kafka-logs”)下對應的topic。(不同broker下儲存的topic不一定相同,所有broker都要看一下)

2、進入zookeeper客戶端刪掉對應topic

        zkCli.sh  -server 127.0.0.1:42182

   找到topic目錄

        ls   /brokers/topics

   刪掉對應topic

    rmr  /brokers/topic/topic-name

   找到目錄

        ls    /config/topics

   刪掉對應topic

        rmr  /config/topics/topic-name  

 

以上兩步全部執行才算徹底刪除topic
---------------------
作者:桃花惜春風
來源:CSDN
原文:https://blog.csdn.net/xiaoyu_bd/article/details/52268647
版權宣告:本文為博主原創文章,轉載請附上博文連結!