Docker（Compose）客户端过早连接到 Kafka

Question

我正在尝试使用 Docker 和 Docker Compose 运行 Kafka。这是docker-compose.yml：

version: "2"

services:
  zookeeper:
    image: "wurstmeister/zookeeper"
    ports:
      - "2181:2181"

  kafka:
    build:
      context: "./services/kafka"
      dockerfile: "Dockerfile"
    ports:
      - "9092:9092"
    environment:
      KAFKA_ADVERTISED_HOST_NAME: "0.0.0.0"
      KAFKA_CREATE_TOPICS: "test:1:1"
      KAFKA_ZOOKEEPER_CONNECT: "zookeeper:2181"
    volumes:
      - "/var/run/docker.sock:/var/run/docker.sock"

  users:
    build:
      context: "./services/users"
      dockerfile: "Dockerfile"
    ports:
      - "4001:4001"
    environment:
      NODE_ENV: "develop"
      ZOOKEEPER_HOST: "zookeeper"
      ZOOKEEPER_PORT: "2181"
    volumes:
      - "./services/users:/service"

用户服务仅尝试连接（使用 Node.js 中的 kafka-node）并监听一个主题并在每次运行时向其发布一条消息。

问题是我不断收到拒绝连接错误。我正在使用 Dockerize 等待 kafka 端口在 Dockerfile 中可用，并带有 CMD dockerize -wait tcp://kafka:9092 node /service/index.js 行。

它在启动用户容器之前等待端口可用并且该系统工作，但它不是在正确的时间。看来Kafka在选举出leader之前就开放了9092端口。

当我先运行 Kafka 并让它完全启动然后运行我的应用程序时，它运行顺利。

如何在开始服务之前等待正确的时间？

Answer 1

尝试 docker-compose 2.1 或 3 版，因为它包含一个 healthcheck 指令。
以“Docker Compose wait for container X before starting Y”为例。

你可以：

depends_on:
  kafka:
    condition: service_healthy

然后在 kafka 中添加：

healthcheck:
    test: ["CMD", ...]
    interval: 30s
    timeout: 10s
    retries: 5

例如使用 curl 命令来测试 kafka 是否已选举出领导者。