容器启动时应用程序错误地解析了 Docker 别名

Question

我正在创建两个 docker-compose 文件（主要是因为我不想在开发我的应用程序时必须不断重启我的基础设施。）它们需要驻留在同一个 docker 网络上，以便它们可以使用别名进行连接。

这些文件类似于以下内容：

应用程序：

version: '3.5'

networks:

  default:

    name: kafka_network

    driver: bridge

services:

  client:

    build:

      context: .

      dockerfile: ./Dockerfile

    working_dir: /app/

    command: ./client

    environment:

      BADDR: kafka:9092

      CGROUP: test_group

      TOPICS: my-topic

基础设施：

version: '3.5'

networks:

  default:

    name: kafka_network

    driver: bridge

services:

  zookeeper:

    image: confluentinc/cp-zookeeper:latest

    ports:

      - 2181:2181

    environment:

      ZOOKEEPER_CLIENT_PORT: 2181

      ZOOKEEPER_TICK_TIME: 2000

  kafka:

    image: confluentinc/cp-kafka:latest

    depends_on:

      - zookeeper

    ports:

      - 9092:9092

    environment:

      KAFKA_BROKER_ID: 1

      KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181

      KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://kafka:29092,PLAINTEXT_HOST://localhost:9092

      KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: PLAINTEXT:PLAINTEXT,PLAINTEXT_HOST:PLAINTEXT

      KAFKA_INTER_BROKER_LISTENER_NAME: PLAINTEXT

      KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1

我的问题是客户端没有正确解析 kafka:9092 ...它总是解析为127.0.0.1:9092.

错误：

Broker:  kafka:9092

Consumer_Group:  my_group

Topics:  [my-topic]

Created Consumer rdkafka#consumer-1

% Error: GroupCoordinator: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT)

在本地运行时，它似乎运行良好，所以我真的很困惑可能是什么问题。如果有人对此有所了解，我将不胜感激！

当地的：

[procyclinsur@P-428 client]$ ./client

Broker:  localhost:9092

Consumer_Group:  my-group

Topics:  [my-topic]

Created Consumer rdkafka#consumer-1

% AssignedPartitions: [my-topic[0]@unset]

% Message on my-topic[0]@0:

hello mate

Answer 1

这是与您的 Kafka 配置相关的问题——根本与 docker 无关。旁观：  KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://kafka:29092,PLAINTEXT_HOST://localhost:9092这意味着您为您的 Kafka 设置了 2 个侦听器，您的客户端在连接时将在 Kafka 的协议中收到这些侦听器。因此，当您连接到端口 9092 时，您的客户端将尝试通过“localhost”获取 Kafka，而当您连接到端口 29092 时，您的客户端将尝试通过“kafka”DNS 名称获取 Kafka。它在本地为您工作，因为您的 Kafka 容器通过 docker 端口部分暴露在 localhost:9092 上。