0

我在另一台机器上有一个 3 节点 Kafka 集群,我无法在其中远程连接和使用 Spring Boot 应用程序的消息。我已经像这样更改了我的配置文件:

advertised.listeners=PLAINTEXT://<myActual IP address>:9092

这是我的application.yml:

spring:
  kafka:
    consumer:
      bootstrap-servers: :9092,:9093,:9094
      group-id: test-consumer-group
      auto-offset-reset: earliest
      key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
      value-deserializer: org.apache.kafka.common.serialization.StringDeserializer

当我运行应用程序时,我收到了这个错误:

2020-10-26 12:47:52.524 WARN 4524 --- [| adminclient-1] 
org.apache.kafka.clients.NetworkClient : [AdminClient clientId=adminclient-1] 
Connection to node -1 (localhost/127.0.0.1:9092) could not be established. 
Broker may not be available.
4

1 回答 1

1

bootstrap-servers: :9092,:9093,:9094

您需要指定主机名或 IP 地址。

bootstrap-servers: some.host:9092,some.host:9093,some.host:9094

于 2020-10-26T13:44:58.787 回答