我有一个微服务运行Kafka消费群订阅两个不同的主题(如topic1和topic2)。使用以下命令验证订阅- bin\windows\kafka-consumer-groups.bat --bootstrap-server localhost:9092 --describe --group mygroupId
看来效果不错。
但是,服务日志正在生成警告,因为- [Consumer clientId=myclientId, groupId=mygroupId] Error while fetching metadata with correlation id 2369423 : {topic1,topic2=UNKNOWN_TOPIC_OR_PARTITION}
我已经验证了主题名,它们确实存在。还尝试通过控制台运行生产者和消费者,消息已成功发布和接收。还使用下面的命令验证了主题上的acl,并且输出为空。 kafka-acls.sh --authorizer-properties zookeeper.connect=zookeeperhost:2181 --list --topic topic1
有人能帮我解释一下为什么会出现这个未知的主题或分区错误吗?
暂无答案!
目前还没有任何答案,快来回答吧!