2017-03-16 52 views
0

我試圖用8個分區和2個複製刪除一個Kafka主題。首先,我使用kafka-topic.sh --delete命令刪除該主題。然後我使用zkCli.sh -server slave1 ..... slave3和rmr/brokers/topics/MY_TOPIC。Zookeeper客戶端不能rmr/brokers/topics/MY_TOPIC

但是我仍然在/ brokers/topics /中看到該主題。我試着重新啓動卡夫卡,一切仍然如此。

順便說一句,有1個分區和1個副本的主題可以成功刪除。

回答

0

您可以設置服務器屬性,以使卡夫卡的話題刪除service.properties

delete.topic.enable = true 

下面提到如果手動刪除使用RMR /經紀人/主題

行添加/ MY_topic那麼你還需要從zookeeper的其他節點中刪除與該主題有關的主題相關元數據。還需要刪除kafka服務器上的kafka主題導演。

啓用主題刪除屬性並執行kafka-topics.sh更清晰 - 刪除