运行此命令后： 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?
2条答案
按热度按时间mm5n2pyu1#
我已经创建了4个代理，复制因子是3，我正在检查所有代理。这就是为什么它没有显示主题。当我检查了3个经纪人，它给了我正确的信息，没有给出任何错误。
sshcrbum2#
主题名称与主题元数据、主题中每个分区的引线等一起存储在zookeeper中。
在您的情况下，zookeeper似乎有此信息，但可能Kafka数据已损坏或已删除。
停止kafka，zookeeper，删除zookeeper数据目录，kafka数据目录，然后再次启动这两个服务。
重新创建你的主题，它应该工作良好。