Kafka 消费者在获取相关 ID 为 22 的元数据时出错:{FINSRVC_TOPIC_PROD=UNKNOWN_TOPIC_OR_PARTITION}

问题描述 投票:0回答:1

当我第一次在生产中部署它并使用消息时,我的 springboot kafka 消费者微服务运行良好。
我上周重新部署了微服务,做了一些小的更改,然后它开始发出此警告。

2022-07-10 03:30:02.653  WARN 1 --- [ntainer#0-0-C-1] org.apache.kafka.clients.NetworkClient   : [Consumer clientId=consumer-finsrvc-consumer-group-1, groupId=finsrvc-consumer-group] Error while fetching metadata with correlation id 22 : {FINSRVC_TOPIC_PROD=UNKNOWN_TOPIC_OR_PARTITION}

变化是-

1:在配置文件中将FixedBackOff从(5000L,3)更改为(2000L,2)

2:在dockerfile中,添加以下RUN命令

RUN apt-get update && DEBIAN_FRONTEND=noninteractive apt-get upgrade -y && apt-get clean -y && rm -rf /var/lib/apt/lists/*

附加信息:

  1. Kafka 代理设置没有变化。
  2. 我使用的是Kafka 3.2.0版本和springboot 2.6.2版本
  3. Kafka 集群包含托管在 AWS 中的多个代理,但微服务托管在谷歌云中。
  4. 当微服务抛出警告时,幸运的是它也在消耗消息。只是担心是否有消息被丢弃。
apache-kafka
1个回答
0
投票

此异常表明您正在尝试将事件发布到不存在的主题中。您可以将值设置为 auto.create.topics.enable = true 并尝试一下吗?另外,您可能需要检查升级后以下属性是否被默认覆盖。

listeners=PLAINTEXT://localhost:9092
advertised.listeners=PLAINTEXT://localhost:9092
© www.soinside.com 2019 - 2024. All rights reserved.