我正在尝试删除一个包含8个分区和2个副本的Kafka主题。首先,我使用kafka-topic.sh --delete命令删除该主题。然后我使用了zkCli.sh -server slave1.....slave3和rmr /brokers/TOPIC/MY_TOPIC。
然而,我仍然在/brokers/ topic /中看到了这个主题。我试着重启Kafka,一切照旧。
顺便说一句,可以成功删除1个分区和1个副本的主题。
发布于 2017-03-16 21:50:46
您可以设置服务器属性,以允许删除kafka主题
在service.properties中添加下面提到的行
delete.topic.enable = true
如果使用rmr /brokers/ topic /MY_ topic手动删除,那么还需要从zookeeper中的其他节点中删除与主题相关的元数据,该主题的前消费者信息。还需要删除kafka服务器上的kafka topic director。
启用主题删除属性并执行kafka-topics.sh --delete会更干净
https://stackoverflow.com/questions/42835277
复制相似问题