主题 [test-topic-new] 存在/不存在且 missingTopicsFatal 为真答案

【问题标题】：Topic(s) [test-topic-new] is/are not present and missingTopicsFatal is true主题 [test-topic-new] 存在/不存在且 missingTopicsFatal 为真
【发布时间】：2020-09-21 07:48:36
【问题描述】：

我在服务器 (12.255.123.789) 中运行一项消费者服务。一个集群中有3个kafka服务器（XX.XXX.XXX.123, XX.XXX.XXX.124, XX.XXX.XXX.125）和三个zookeeper服务器（YY.YYY.YYY.123, YY.YYY. YYY.124, YY.YYY.YYY.125) 正在运行。我的消费者属性是

spring.kafka.consumer.bootstrap-servers=XX.XXX.XXX.123:9092,XX.XXX.XXX.124:9092,XX.XXX.XXX.125:9092
spring.kafka.consumer.group-id: prod
#spring.kafka.consumer.auto-offset-reset: earliest
spring.kafka.consumer.auto-offset-reset: latest
spring.kafka.consumer.key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
spring.kafka.consumer.value-deserializer: org.springframework.kafka.support.serializer.JsonSerializer
spring.kafka.listener.concurrency: 6

我已经用这个命令在kafka server(XX.XXX.XXX.123,XX.XXX.XXX.124,XX.XXX.XXX.125)中创建主题

bin/kafka-topics.sh --create --zookeeper YY.YYY.YYY.123:2181,YY.YYY.YYY.124:2181,YY.YYY.YYY.125:2181 --replication-factor 2 --partitions 1 --topic test-topic-new --config cleanup.policy=delete --config delete.retention.ms=60000

在 12.255.123.789 服务器上启动我的消费者服务时，我遇到了以下异常 -

org.springframework.context.ApplicationContextException: Failed to start bean 'org.springframework.kafka.config.internalKafkaListenerEndpointRegistry'; nested exception is java.lang.IllegalStateException: Topic(s) [test-topic-new] is/are not present and missingTopicsFatal is true

我在这里做错什么了吗？

【问题讨论】：

检查你的Kafka主题是否是使用bin/kafka-topics.sh --list --zookeeper YY.YYY.YYY.123:2181创建的。

标签： java spring spring-boot apache-kafka kafka-consumer-api

【解决方案1】：

kafka 服务器之间的通信没有建立。这就是应用程序无法找到主题的原因。我们需要设置一个领导节点。此应用程序运行顺利后。

advertised.listners=PLAINTEXT://<serverIP:port>

【讨论】：