所以我运行一个Kafka经纪人和一个Kafka客户,我去创建了关于Kafka经纪人的以下主题
kafka-topics --zookeeper zookeeper:2181 --create --topic hcf.pool.fox-dtemplate-2 --partitions 1 --replication-factor 1
主题创作进行得很好,当我列出Kafka的主题,我可以看到它。
现在,当我启动运行kafka消费者的spring boot应用程序时。我经常看到控制台上打印的信息
2021-03-29 14:15:19.734 WARN 96875 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher : [Consumer clientId=####, groupId=####] Received unknown topic or partition error in ListOffset request for partition hcf.pool.fox-dtemplate-2
这条线每200毫秒就会在控制台上打印多次。
知道我做错了什么吗。
Kafkadocker图像-confluentinc/cp-kafka:5.5.1
另外,我如何检查Kafka消费者版本?
1条答案
按热度按时间3hvapo4f1#
尝试通过Kafka而不是zk来创建主题