当我第一次在生产中部署它并使用消息时,我的 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/*
附加信息:
此异常表明您正在尝试将事件发布到不存在的主题中。您可以将值设置为 auto.create.topics.enable = true 并尝试一下吗?另外,您可能需要检查升级后以下属性是否被默认覆盖。
listeners=PLAINTEXT://localhost:9092
advertised.listeners=PLAINTEXT://localhost:9092