删除Kafka 0.8.1.1中的主题
bin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic test
但是,这将导致以下消息：
Command must include exactly one action: --list, --describe, --create or --alter
如何删除此主题？
共有1个答案
在0.8.1.1中删除主题并不总是有效的
删除应该在下一个版本0.8.2中起作用
kafka-topics.sh --delete --zookeeper localhost:2181 --topic your_topic_name
Topic your_topic_name is marked for deletion.
Note: This will have no impact if delete.topic.enable is not set to true.
是否可以删除一个主题？
-
我想删除所有空的Kafka主题（定期从cron）。我在文档中找不到一个这样做的命令？转到脚本： 但是，这包括已经过期的消息？在不使用消费者的情况下，如何在主题中找到实际的当前计数？
-
我正在测试Kafka主题的工作，但我不明白删除是如何工作的。 我创建了一个简单的主题 在此之后，我创建了一个生产者，并发送了一些消息。消费者没有问题地接收到消息。但我预计，一分钟后，如果重复了消费者，它不会显示消息，因为它们肯定已经被删除了。但这种行为不会发生。 如果我用ksql创建一个查询，那也是一样的。消息总是会出现。 我想我不明白删除是怎么回事。 3）制作人留言 4）消费者 消费者会显示这四
-
我有几个Kafka的题目作为测试。现在我想通过清理我的Kafka主题列表来把它们全部除掉。我设置了变量，然后停止并重新启动zookeeper和kafka服务器。但什么也帮不了我。主题仍然存在，“标记为删除”。我读了这个问题，但没有找到任何答案。否则，这里建议手动移除任何主题。但我该怎么做呢？在故事的结尾，手动或通过命令行，我如何永久删除Kafka主题？
-
问题内容： 我有以下表模式，它将user_customers映射到实时MySQL数据库的权限： 我想删除user_customer_id和Permission_id的主键，并保留id的主键。 当我运行命令时： 我收到以下错误： 如何删除列的主键？ 问题答案： 如果没有索引，则维护自动增量列会变得太昂贵，这就是为什么要求将自动增量列作为索引的最左侧部分的原因。 您应该在删除键之前删除autoincr
-
因此，我是使用Apache Kafka的新手，我正在尝试创建一个简单的应用程序，以便我可以尝试更好地理解API。我知道这个问题在这里被问了很多，但是我该如何清除存储在主题上的消息/记录？ 我看到的大部分回答都是说更改消息保留时间或者删除
-
我看过与此相关的类似问题，但并没有找到正确的答案。我只想从 Kafka 主题中删除消息，而不是更改保留超时。我已经安装了kafka_2.11-0.8.2.1，并使用蝙蝠文件在Windows上运行它。我想知道我是否可以删除主题中发布的所有消息，而不删除整个主题。