Kafka主题删除不起作用
我使用的是Kafka版本0.8.2。在开发过程中，我想我可能需要删除一个主题。所以我所做的是在服务器配置文件中放入以下一行，并启动两台kafka服务器。
delete.topic.enable=true
当我需要删除一个主题并运行以下命令时,
bin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic MyTopic
现在距我运行“删除主题”命令已经17个小时了，但Kafka仍在向我显示该主题已标记为删除。是Kafka的虫子还是我在这里做错了什么？因为在我看来这不正常。有人能就此澄清一下吗？
共有1个答案
如果以前有delete.topic.enable=false，则无法删除kafka主题。您可以更改此值，但它不影响当前可用的主题。所以，您可以尝试手动删除它。
-
主题的最后状态： 组,主题,分区,当前偏移量,日志结束偏移量,滞后,所有者G.AB_KAFF,T.AB_KAFF,0,5,5,0,Consumer-2_/127.0.0.1 G.AB_KAFF,T.AB_KAFF,1,5,5,0,Consumer-2_/127.0.0.1 现在我删除主题。并将邮件发布到此主题 那么为什么Kafka要把滞后设定为-ve数。这难道不是一个潜在的问题吗？ 假设我再次订阅
-
但是,这将导致以下消息： 如何删除此主题？
-
我想删除所有空的Kafka主题（定期从cron）。我在文档中找不到一个这样做的命令？转到脚本： 但是，这包括已经过期的消息？在不使用消费者的情况下，如何在主题中找到实际的当前计数？
-
在kafka中，我在中将保留策略设置为3天 主题将设置为(48h)。 但是，文件夹/tmp/kafka-logs中仍然有旧数据，并且没有任何数据被删除。我等了几个小时才换了那些房产。
-
我们有一个两节点的kafka集群，具有和设置为。我们的应用程序读取公共请求主题，并响应客户端在请求负载中提供的响应主题。 设置为，因为我们的客户端具有自动缩放环境，其中新工作人员将从新响应主题中读取。由于客户端的一些实现问题，有很多创建的主题从未使用过（结束偏移量为），我们正试图清理这些主题。 问题是，删除主题后，它几乎立即被重新创建。这些主题没有任何消费者（因为听它的工人已经死了）。 我已经尝试
-
我有几个Kafka的题目作为测试。现在我想通过清理我的Kafka主题列表来把它们全部除掉。我设置了变量，然后停止并重新启动zookeeper和kafka服务器。但什么也帮不了我。主题仍然存在，“标记为删除”。我读了这个问题，但没有找到任何答案。否则，这里建议手动移除任何主题。但我该怎么做呢？在故事的结尾，手动或通过命令行，我如何永久删除Kafka主题？