收到警告“在分区hcf.pool.fox-dtemplate-2的listoffset请求中收到未知主题或分区错误”

gtlvzcf8  于 2021-07-13  发布在  Java
关注(0)|答案(1)|浏览(306)

所以我运行一个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消费者版本?

3hvapo4f

3hvapo4f1#

尝试通过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.

相关问题