Kafka-消费者无法启动：连接被拒绝-127.0.0.1:9092的连接（2）[重复]答案

【问题标题】：Kafka - Consumer failed to start: Connection refused - connect(2) for 127.0.0.1:9092 [duplicate]Kafka-消费者无法启动：连接被拒绝-127.0.0.1:9092的连接（2）[重复]
【发布时间】：2020-05-25 14:33:41
【问题描述】：

我正在尝试在 docker 网络中本地启动并运行我的一项服务，但不断收到 “Consumer failed to start: Connection denied - connect(2) for 127.0.0.1:9092” strong> 异常。

zookeeper:
  image: wurstmeister/zookeeper:3.4.6
  restart: always
  expose:
      - "2181"



kafka:
      depends_on:
          - zookeeper
      environment:
          KAFKA_ADVERTISED_LISTENERS: INSIDE://kafka:9093,OUTSIDE://localhost:9092
          KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: INSIDE:PLAINTEXT,OUTSIDE:PLAINTEXT
          KAFKA_LISTENERS: INSIDE://0.0.0.0:9093,OUTSIDE://0.0.0.0:9092
          KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
          KAFKA_INTER_BROKER_LISTENER_NAME: INSIDE
      hostname: kafka
      image: wurstmeister/kafka:2.11-2.0.0
      restart: always
      ports:
          - "9092:9092"
      expose:
          - "9093"
      links:
          - zookeeper:zookeeper

这就是我在服务的 docker-compose 中为消费者设置的内容：

  consumers:
    environment:
      - BROKER_URL=host.docker.internal:9092

这是错误信息：

..`block in execute'","/usr/local/bundle/gems/rake-12.3.2/lib/rake/task.rb:273:in `each'"],
"message":"Consumer failed to start: Connection refused - connect(2) for 127.0.0.1:9092"},
"message":"Consumer failed to start: Connection refused - connect(2) for 127.0.0.1:9092",
"@timestamp":"2020-05-24T18:08:09.434+00:00","@version":"1",
"severity":"ERROR","host":"87c5265c6a39"}

更新：检查 Kafkacat 时：

kafkacat -L -b 127.0.0.1:9092
Metadata for all topics (from broker 0: 127.0.0.1:9092/0):
 1 brokers:
  broker 0 at 127.0.0.1:9092 (controller)
 7 topics: ...

检查 Zookeeper CLI 时（在 Docker 内）：

[zk: localhost:2181(CONNECTED) 2] ls /brokers/ids
[1001]

我已经尝试了几乎所有我能找到的东西，但仍然无法理解我错过了什么。

任何帮助将不胜感激，谢谢！

【问题讨论】：

您的消费者在哪里运行？它在 Docker 网络上吗？还是其他地方？
@RobinMoffatt 忘了说，它在 docker 网络中。
您的消费者应该连接到同一 docker 网络中的kafka:9093。 links 也是一个已弃用的功能

标签： docker apache-kafka docker-compose

【解决方案1】：

您连接到错误的侦听器。当您连接到 9092 时，代理返回 localhost 供您的客户端随后连接。连接到 9093，它将使用 Docker 网络中的消费者应该能够解析的kafka。

参考：https://rmoff.net/2018/08/02/kafka-listeners-explained/

【讨论】：