Kafka_彻底删除Topic


Kafka_彻底删除Topic

出现的问题:

生产者可以在生产数据,也可以创建Topic,但消费者消费不到数据。

处理方式:彻底删除所有的 Topic,然后在创建新的 Topic,生产者在生产,消费者可以消费。

彻底删除Topic

1:先把 Kafka停下。

2:删除 Kafka存储目录( server.properties 文件 log.dirs 配置,默认为 "/tmp/kafka-logs" )相关 topic 目录。

3:配置文件中 server.properties 配置delete.topic.enable=true,执行
bin/kafka-topics.sh --bootstrap-server master01:9092 --delete --topic topic_start

4:进入ZK的bin 目录执行 zkCli.sh -server master01:2181,然后执行 ls /brokers/topics, 在然后执行 rmr /brokers/topics/【topic name】

解释说明:

如果配置文件中 server.properties 没有配置delete.topic.enable=true,那么执行命令删除 Topic 的时候会被标记marked for deletion

进入 ZK ,(接第四步 )执行 ls /admin/delete_topics/【topic name】 删除即可。


文章作者: L Q
版权声明: 本博客所有文章除特別声明外,均采用 CC BY 4.0 许可协议。转载请注明来源 L Q !
  目录