kafka-topics.sh----delete--主题“testtopic”不适用于kafka v0.10.1
[1]
Error while executing topic command : Topic targettopic does not exist on ZK path zookeeper.xx.com:2181/chroot
[2016-10-14 11:58:59,919] ERROR java.lang.IllegalArgumentException: Topic streamtargettopic does not exist on ZK path zookeeper.xx.com:2181/chroot
at kafka.admin.TopicCommand$.deleteTopic(TopicCommand.scala:169)
at kafka.admin.TopicCommand$.main(TopicCommand.scala:69)
at kafka.admin.TopicCommand.main(TopicCommand.scala)
共有1个答案
您可以使用以下命令检查zookeeper中可用的主题列表。
bin/kafka-topics.sh --list --zookeeper localhost:2181
还可以在server.properties中设置以下属性
delete.topic.enable=true
然后尝试使用
bin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic test
-
我正在将旧的对话框切换到DialogFragment，但主题和样式似乎不起作用。
-
我使用的是Kafka版本0.8.2。在开发过程中，我想我可能需要删除一个主题。所以我所做的是在服务器配置文件中放入以下一行，并启动两台kafka服务器。 当我需要删除一个主题并运行以下命令时, 现在距我运行“删除主题”命令已经17个小时了，但Kafka仍在向我显示该主题已标记为删除。是Kafka的虫子还是我在这里做错了什么？因为在我看来这不正常。有人能就此澄清一下吗？
-
我有一些关于Kafka主题分区->spark流媒体资源利用的用例，我想更清楚地说明这些用例。 我使用spark独立模式，所以我只有“执行者总数”和“执行者内存”的设置。据我所知并根据文档，将并行性引入Spark streaming的方法是使用分区的Kafka主题->RDD将具有与Kafka相同数量的分区，当我使用spark-kafka直接流集成时。 因此，如果我在主题中有一个分区和一个执行器核心，
-
我在一个网站上工作，遇到了一个问题，点击我的“删除”链接会出现一个错误页面。在localhost上运行良好-无法理解为什么在Heroku站点上会有所不同。 有人知道这是怎么回事吗？ 我的“图片”控制器： 我的图片/新视图： 以下是我尝试删除图片时的heroku日志(从导航到新图片页面开始(同一视图中的新建和编辑功能): 2015-11-15T16:13:49.189857 00:00 heroku
-
上下文 我编写了几个小的Kafka Connect连接器。一个每秒只生成随机数据，另一个将其记录在控制台中。它们与模式注册表集成，因此数据使用Avro序列化。 我使用Landoop提供的fast data dev Docker映像将它们部署到本地Kafka环境中 基本设置工作，并每秒生成一条记录的消息 但是，我想更改主题名称策略。默认设置生成两个主题：
-
当一个DLQ被设置为一个Spring云流Kafka消费者时，DLQ写入的主题可以被分区吗？我有一个要求，使密钥等于一个特定的字段，我想知道这将如何与Spring云流。