如何使用docker-compose文件创建Kafka主题并解决命令执行报错问题

问题原因 #

• 命令格式错误：你在docker-compose的command字段使用数组语法时，将bash -c "xxx"整体作为单个数组元素，Docker会将整段字符串识别为单个可执行文件去查找，因此触发找不到可执行文件的报错。
• 逻辑错误：直接覆盖Kafka容器的默认启动命令，会导致Kafka broker本身不会启动，即便命令格式调整正确，执行完创建主题的逻辑后容器也会直接退出，无法正常提供Kafka服务。

最优解决方案 #

Bitnami Kafka镜像官方自带开箱即用的自动创建主题能力，无需自定义command配置，直接添加对应环境变量即可：
你的kafka-1服务配置调整如下：

kafka-1:
    container_name: kafka-1 
    image: bitnami/kafka
    depends_on: 
      - zookeeper-1
    ports: 
      - 29092:29092
      - 9092:9092
    environment:
      - KAFKA_ZOOKEEPER_CONNECT=zookeeper-1:2181
      - KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://localhost:29092
      - ALLOW_PLAINTEXT_LISTENER=yes
      # 新增自动创建主题配置，格式为 主题名:分区数:副本数，多个主题用逗号分隔
      - KAFKA_CREATE_TOPICS=demo-topic:1:1

配置生效后容器启动时会自动创建指定主题，不影响原有Kafka broker的启动逻辑，官方已默认处理重启后重复创建主题的报错问题。

自定义命令方案（可选） #

如果需要自定义执行更多初始化逻辑，可调整command格式，在保留原有Kafka启动逻辑的基础上执行主题创建命令：

command:
  - bash
  - -c
  - "/opt/bitnami/scripts/kafka/run.sh & sleep 15 && kafka-topics --create --if-not-exists --zookeeper zookeeper-1:2181 --replication-factor 1 --partitions 1 --topic demo-topic && wait"

sleep时间可根据你的容器启动速度调整，确保Kafka完全启动后再执行创建命令。

内容的提问来源于stack exchange，提问作者David_K