如何永久删除kafka主题？

嗨运行此命令kafka-topics --zookeeper localhost --delete --topic MyTopic如何永久删除kafka主题？

这样的工作。

[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日志目录时，主题被删除，但几分钟后它又重新出现。

当我看卡夫卡的日志，我看到了

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)

所以它似乎是重新创建不知何故呢？

谢谢

来源

2016-06-28 user432024

默认情况下禁用主题删除选项。要启用它，请将服务器配置设置为delete.topic.enable = true并重新启动kafka。然后使用下面的命令：斌/ kafka-topics.sh --zookeeper zk_host：端口/ chroot的--delete --topic my_topic_name – srujana

我确实有它使否则它为什么会物理删除的文件夹，然后重新创建它？ – user432024

另外我运行完全相同的命令，因为你说的唯一区别是我从你和我的看到的是chroot。 – user432024

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

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

来源

2016-06-30 11:07:47

如何永久删除kafka主题？

回答

相关问题