【问题标题】:Getting the warning "Received unknown topic or partition error in ListOffset request for partition hcf.pool.fox-dtemplate-2"收到警告“在分区 hcf.pool.fox-dtemplate-2 的 ListOffset 请求中收到未知主题或分区错误”
【发布时间】: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


【解决方案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.            

【讨论】:

  • 那么我应该为参数 --bootstrap-server 输入什么?
  • Spring Bootstrap 服务器中的任何内容。
  • 或者你可以让spring通过添加一个NewTopic @Bean来创建它。请参阅 spring-kafka 参考手册配置主题。
  • 我也试过这样做,`@Bean public NewTopic templateEventTopic() { return TopicBuilder.name(KafkaConfigUtil.templateTopicName) .partitions(numPartition) .replicas(numReplicas) .build(); }' 还是不行,我也试过提供--bootstrap-server,同样的问题!
  • 还有。如果它不起作用,请编辑问题以显示您的代码和配置。
猜你喜欢
  • 2019-05-23
  • 1970-01-01
  • 1970-01-01
  • 1970-01-01
  • 2013-03-03
  • 1970-01-01
  • 2020-12-17
  • 1970-01-01
相关资源
最近更新 更多