kafka删除topic


手动:

  • 删除kafka存储目录(server.properties文件log.dirs配置,默认为"/tmp/kafka-logs")相关topic目录
  • 删除zookeeper "/brokers/topics/"目录下相关topic节点

命令+手动:

bin/kafka-run-class.sh kafka.admin.DeleteTopicCommand --topic mrtopic --zookeeper cmcc1:,cmcc2:,cmcc3:
  • 删除kafka存储目录(server.properties文件log.dirs配置,默认为"/tmp/kafka-logs")相关topic目录

如果你要删除一个topic并且重建,那么必须重新启动kafka,否则新建的topic在zookeeper的/brokers/topics/test-topic/目录下没有partitions这个目录,也就是没有分区信息。


上一篇:kafka删除topic详解


下一篇:使用Java API创建(create),查看(describe),列举(list),删除(delete)Kafka主题(Topic)