如何永久删除kafka主题？答案

【问题标题】：How to permanently delete kafka topic?如何永久删除kafka主题？
【发布时间】：2016-10-31 05:16:58
【问题描述】：

您好，运行此命令 kafka-topics --zookeeper localhost --delete --topic MyTopic

这行得通。

[2016-06-28 14:22:43,533] INFO Deleting index /data1/kafka/MyTopic-XX/00000000000000000000.index (kafka.log.OffsetIndex)
[2016-06-28 14:22:43,533] INFO Deleted log for partition [MyTopic,xx] in /data1/kafka/MyTopic-xx. (kafka.log.LogManager)

其中 XX 是分区。当我查看 kafka 日志目录时，该主题已被删除，但几分钟后它又出现了。

当我查看 kafka 日志时，我看到...

 INFO Created log for partition [MyTopic,XX] in /data1/kafka with properties {compression.type -> producer, message.format.version -> 0.10.0-IV1, file.delete.delay.ms -> 60000, max.message.bytes -> 1000012, message.timestamp.type -> CreateTime, min.insync.replicas -> 1, segment.jitter.ms -> 0, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> true, retention.bytes -> -1, delete.retention.ms -> 86400000, cleanup.policy -> delete, flush.ms -> 9223372036854775807, segment.ms -> 604800000, segment.bytes -> 1073741824, retention.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760, flush.messages -> 9223372036854775807}. (kafka.log.LogManager)
[2016-06-28 13:59:39,623] INFO Partition [MyTopic,XX] on broker 0: No checkpointed highwatermark is found for partition [MyTopic,XX] (kafka.cluster.Partition)

所以它似乎以某种方式重新创建它？

谢谢

【问题讨论】：

主题删除选项默认禁用。要启用它，请设置服务器配置 delete.topic.enable=true 并重新启动 kafka。然后使用以下命令：bin/kafka-topics.sh --zookeeper zk_host:port/chroot --delete --topic my_topic_name
我确实启用了它，否则为什么它会物理删除文件夹然后重新创建它？
我也运行了与你所说的完全相同的命令，我从你的和我的中看到的唯一区别是 chroot。
好的，我重新启动了服务器，所有主题都消失了。我正在尝试使用上述命令并手动删除主题，但它们不断回来。我可能有一个流氓动物园管理员在屏幕上运行，我忘记了哈哈
Err 不，它仍在执行此操作，尽管重新启动确实阻止了它执行它正在执行的操作。因此，即使我停止 zookeeper 和 kafka，然后物理删除文件，主题仍然会回来

标签： apache-kafka

【解决方案1】：

在代理中禁用auto.create.topics.enable 属性。

注意：此属性默认启用。生产者/消费者对不存在的主题的请求会自动创建。如果要禁用它，请确保在启动客户端应用程序之前创建所需的主题。

【讨论】：