远程 Kafka 消费者答案

【问题标题】：Remote Kafka Consumer远程 Kafka 消费者
【发布时间】：2021-02-08 15:41:35
【问题描述】：

我在另一台机器上有一个 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.

【问题讨论】：

您的错误说它正在连接到本地主机，那么您为什么不提供另一台机器的地址？注意：在一台机器上运行 3 个代理仍然是单点故障，不会提高弹性或性能

标签： spring-boot apache-kafka spring-kafka apache-kafka-connect kafka-cluster

【解决方案1】：

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

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

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

【讨论】：

我做了，但它不能远程工作，但它可以正常与 localhost 一起工作。
很抱歉在这里提出另一个问题，但您是否设法解决了这个问题？我在这里面临同样的情况。