(KafkaAdmin.java:177) [spring-kafka-2.5.2.RELEASE.jar:2.5.2.RELEASE]
at org.springframework.kafka.core.KafkaAdmin.afterSingletonsInstantiatedspring.kafka.bootstrap-servers将服务器设置为localhost:9092,下面分别是我的生产者、使用者和主题配置文件。(KafkaAdmin.java:233) [
为了学习Apache Kafka,我开发了一个SpringBoot应用程序,如果我向调用Kafka发送方法的控制器发送POST请求,它会向KafkaTemplate主题发送消息。当我关闭Zookeeper或Kafka时,问题就出现了。如果我这样做了,那么在启动时,我的应用程序的Kafka AdminClient会定期尝试查找broer,但会将此消息发送到控制台
Connection to node -1 could not be established有没有一种方法可以配置应用程序,使其在启动时检查Ka