NingG +

Kafka 0.8.2.0 删除Topic

几点:

修改Kafka配置文件,增加可删除Topic的设置:

delete.topic.enable=true

然后,逐个重启Kafka节点,即可。逐个重启Kafka节点,而对其他系统没有影响,是因为之前已经设置每个数据备份两份:

# The default replication factor for automatically created topics.
default.replication.factor=2

上述,开启可删除topic标识之后,可以删除Topic,操作如下:

bin/kafka-topics.sh --zookeeper zk_host:port/chroot --delete --topic my_topic_name

然后,通过如下命令可以查看topic状态:

$ bin/kafka-topics.sh --zookeeper 168.7.2.165 --list
fdiy - marked for deletion

疑问:为什么topic:fdiy还存在?并且还被标记上marked for deletion?

(TODO)

关于上述marked for deletion的现象,当前并不能确定原因,todo

参考来源:

参考来源

Top