topic在kafka中并不存在

htrmnn0y  于 2021-05-27  发布在  Spark
关注(0)|答案(2)|浏览(707)

运行此命令后: bin/kafka-topics.bat --list --bootstrap-server localhost:6666, localhost:6667, localhost:6668, localhost:6669 输出-测试

After running this command :
``` `bin/kafka-topics.bat --describe --bootstrap-server localhost:6666, localhost:6667, localhost:6668, localhost:6669 --topic Test` 错误:
java.lang.illegalargumentexception:在kafka.admin.topiccommand$.kafka$admin$topiccommand$$ensuretopicexists(topiccommand)中,主题“test”不存在。scala:523)在kafka.admin.topiccommand$adminclienttopicservice.describetopic(topiccommand。scala:301)在kafka.admin.topiccommand$.main(topiccommand。scala:68)在kafka.admin.topiccommand.main(topiccommand.scala)

Can anybody help me in solving this issue?

mm5n2pyu

mm5n2pyu1#

我已经创建了4个代理,复制因子是3,我正在检查所有代理。这就是为什么它没有显示主题。当我检查了3个经纪人,它给了我正确的信息,没有给出任何错误。

sshcrbum

sshcrbum2#

主题名称与主题元数据、主题中每个分区的引线等一起存储在zookeeper中。
在您的情况下,zookeeper似乎有此信息,但可能Kafka数据已损坏或已删除。
停止kafka,zookeeper,删除zookeeper数据目录,kafka数据目录,然后再次启动这两个服务。
重新创建你的主题,它应该工作良好。

相关问题