基本上你想先开始zk，然后是Kafka。然后以某种方式等到Kafka准备好（这是棘手的部分），与Kafka一起完成你的工作（例如，在你的案例中创建主题），然后等到Kafka和zk完成（中断时会发生什么）。

start-zookeeper &
ZK_PID=$!
start-kafka &
KAFKA_PID=$!

# that's the tricky part

wait_for_kafka
create-topic.sh

wait "${KAFKA_PID}"
wait "${ZK_PID}"

如前所述，Kafka的准备可能很棘手——以下方法可能会有所帮助：
等待Kafka响应读取请求（例如，使用 kafka-topic.sh --list （定期）
创建pocket consumer/adminclient（java kafka 0.11+）并获取元数据（类似于上述要点）
检查日志/控制器等的jmxbean是否存在。
正在检查侦听端口可用性

docker compose涵盖了许多在脚本中实现的编排任务。
这个 depends_on 以及 healthcheck 服务配置可用于创建适当的服务依赖关系，其中服务b在运行前等待服务a“正常”。
尽管compose还没有定义短时间运行任务的概念，但是主题创建始终可以在启动时运行，因此立即退出的附加服务可以正常工作。
github上有一个compose定义、dockerfile和check脚本来实现这个依赖项设置。

version: "2.1"

services:

  zookeeper:
    image: deployable/kafka:latest
    command: zookeeper
    ports:
     - "2181:2181"
    healthcheck:
      test: [ "CMD", "/kafka/check.sh", "zookeeper" ]
      interval: 30s
      timeout: 5s
      retries: 3

  kafka:
    image: deployable/kafka:latest
    command: kafka
    environment:
      ADVERTISE_LISTENERS: 'localhost:9092'
    ports:
     - "9092:9092"
    depends_on:
      zookeeper:
        condition: service_healthy
    healthcheck:
      test: ["CMD", "/kafka/check.sh", "kafka" ]
      interval: 30s
      timeout: 5s
      retries: 3

  kafka-setup:
    image: deployable/kafka:latest
    command: setup
    depends_on:
      kafka:
        condition: service_healthy
    environment:
      KAFKA_TOPIC: my-test-topic

我建议将主题创建 Package 到单独的脚本中，该脚本在尝试创建主题之前暂停，并在后台运行kafka服务器。比如：

start-zookeeper &
create-topic.sh &
start-kafka

create-topic.sh如下所示：

sleep 5s
kafka-topics --create...

p、 不过，与其睡觉，不如通过睡眠来了解Kafka的情况 nc -z