如何删除标记为删除的Kafka主题
我有几个Kafka的题目作为测试。现在我想通过清理我的Kafka主题列表来把它们全部除掉。我设置了变量delete.topic.enable=true，然后停止并重新启动zookeeper和kafka服务器。但什么也帮不了我。主题仍然存在，“标记为删除”。我读了这个问题，但没有找到任何答案。否则，这里建议手动移除任何主题。但我该怎么做呢？在故事的结尾，手动或通过命令行，我如何永久删除Kafka主题？
共有1个答案
解决了：手动删除包含Zookeeper和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-0.8.2.2.3中删除一个主题。我已使用以下命令删除该主题： 该命令已成功执行，但是当我运行命令以列出主题时，我可以看到该主题仍然存在，并且显示 标记为“删除” 。 当我创建主题DummyTopic时，它会输出异常，该主题已存在，下面是堆栈跟踪： 请让我知道如何删除该主题。 问题答案： 从0.8.2.x版本开始支持删除主题。您必须首先在所有代理上启用主题删除（设置
-
距今已过去数小时，话题仍未删除。 我看到了一些建议，建议我将放在我的中，然后重新启动Kafka。我试过这个。没奏效。 （为什么默认不设置这个？） 我可以关闭kafka和zookeeper，运行，然后再次启动zookeeper和kafka。但这是相当激烈的。确实应该有一些方法来说服实际上删除一个主题？
-
我正在寻找一种从Kafka主题中删除（完全删除）已消费记录的方法。我知道有几种方法可以做到这一点，例如更改主题的保留时间或删除Kafka logs文件夹。但我要寻找的是一种使用Java API删除某个主题的一定数量记录的方法，如果可能的话。 我试过测试AdminClient API，特别是AdminClient。deleteRecords（recordsToDelete）方法。但如果我没弄错的话，
-
但是,这将导致以下消息： 如何删除此主题？
-
有没有办法从Kafka主题中删除单个记录？我知道有一个脚本kafka-delete-records.sh删除指定主题和分区上指定偏移量之前的记录，但是我希望能够删除我指定的偏移量上的记录。有办法做到吗？ 这不是在Java而是在裸露的Kafka实例上。