收到警告 "Received unknown topic or partition error in ListOffset request for partition hcf.pool.fox-dtemplate-2"

Question

所以我是运行 kafka broker 和 kafka client，我在 kafka broker 上创建了以下主题

kafka-topics --zookeeper zookeeper:2181 --create --topic  hcf.pool.fox-dtemplate-2 --partitions 1 --replication-factor 1

主题创建顺利，当我在kafka上列出主题时，我可以看到它。

现在，当我启动运行 Kafka 消费者的 Spring 启动应用程序时。我经常看到控制台上打印的消息

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消费者版本？

Answer 1

尝试通过 Kafka 而不是 ZK 创建主题

$ kafka-topics 
Create, delete, describe, or change a topic.
Option                                   Description                            
------                                   -----------                            
...
--bootstrap-server <String: server to    REQUIRED: The Kafka server to connect  
  connect to>                              to. In case of providing this, a     
                                           direct Zookeeper connection won't be 
                                           required.                            
...
--zookeeper <String: hosts>              DEPRECATED, The connection string for  
                                           the zookeeper connection in the form 
                                           host:port. Multiple hosts can be     
                                           given to allow fail-over.

收到警告 "Received unknown topic or partition error in ListOffset request for partition hcf.pool.fox-dtemplate-2"

Getting the warning "Received unknown topic or partition error in ListOffset request for partition hcf.pool.fox-dtemplate-2"

spring

apache-kafka

spring-boot

spring-kafka

confluent-platform