【发布时间】:2021-06-25 22:21:45
【问题描述】:
所以我正在运行一个 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 毫秒就会在控制台上打印多次。
任何想法我做错了什么。
Kafka docker 镜像 - confluentinc/cp-kafka:5.5.1
另外,如何查看 Kafka 消费者版本?
【问题讨论】:
-
您是否在代码中使用了正确的引导服务器?
标签: spring spring-boot apache-kafka spring-kafka confluent-platform