远程 Kafka 消费者

Question

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

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.

Answer 1

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

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

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

远程 Kafka 消费者

Remote Kafka Consumer

apache-kafka

spring-boot

spring-kafka

apache-kafka-connect

kafka-cluster