Spring Boot Kafka 启动错误 "Connection to node -1 could not be established. Broker may not be available."

Question

我正在尝试使用 Java 12 在本地主机上使用 Spring Boot 2.1.7.RELEASE 启动 Spring-Kafka。

得到错误:
“org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-1, groupId=inter] 无法建立到节点 -1 的连接。代理可能不可用。”

我尝试将 Java 版本切换到 11 和 8 以及各种属性

spring:
  kafka:
    consumer:
      #bootstrap-servers: localhost:9092
      group-id: inter
      auto-offset-reset: earliest
      key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
      value-deserializer: org.apache.kafka.common.serialization.StringDeserializer
    producer:
      bootstrap-servers: localhost:9092

@Service
public class KafkaHalloWorldMessagingService {

    private KafkaTemplate<String, String> kafkaTemplate;

    @Autowired
    public KafkaHalloWorldMessagingService(KafkaTemplate<String, String> kafkaTemplate) {
        this.kafkaTemplate = kafkaTemplate;
    }

    public void sendHalloToTheSystem(String messageToSend) {
        kafkaTemplate.send("interlinked.hallo.topic", messageToSend);
    }
}

@Component
public class KafkaHalloWorldListener {

    @KafkaListener(topics = "interlinked.hallo.topics", groupId = "inter")
    public void handle(String messageToListenTo) {
        System.out.println(messageToListenTo.toUpperCase());
    }
}

2019-08-22 16:25:20.580 WARN 5865 --- [restartedMain] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-1, groupId=inter] 无法建立到节点 -1 的连接。经纪人可能不可用。

Answer 1

确保 yml 文件中的 bootstrap server 值和 Kafka server.properties 文件中的 listener 值相同。

更新 server.properties 文件中的这两个值。
在Kafka下载目录的config文件夹中可以看到。

zookeeper.connect=您的 IpV4 地址:2181

listeners=PLAINTEXT://您的 IpV4 地址:9092

例如:zookeeper.connect=10.147.2.161:2181

为什么消费者的引导服务器属性被注释掉了？

消费者也请使用生产者的引导服务器值。
制作人:
引导服务器:=您的 IpV4 地址:9092
消费者:
引导服务器:=您的 IpV4 地址:9092:

希望你的动物园管理员和 kafka 正常运行。