Docker环境下CLI创建Kafka Topic报错，卷配置无效求助

问题根源分析 #

• 脚本路径错误：你使用的confluentinc/cp-server镜像中，Kafka命令行工具并未放在/opt/kafka/bin路径下，而是已加入系统环境变量，直接调用命令名即可。
• 卷挂载覆盖关键目录：你给broker服务挂载的./broker/data:/opt/kafka会覆盖容器内原有的/opt/kafka目录，导致工具脚本丢失。
• 过时命令参数：新版Kafka推荐用--bootstrap-server指定Broker地址，--zookeeper参数已逐步被废弃。

具体解决步骤 #

步骤1：用正确命令创建Topic #

直接调用kafka-topics命令（无需完整路径），改用--bootstrap-server参数，同时用固定容器名broker代替易变的容器ID：

docker exec -it broker kafka-topics --create --bootstrap-server broker:29092 --replication-factor 1 --partitions 1 --topic my-topicss

步骤2：修复broker的卷挂载配置 #

修改docker-compose.yml中broker的volumes配置，将数据挂载到容器的Kafka专属数据目录，避免覆盖关键路径：

volumes:
  - ./broker/data:/var/lib/kafka/data

修改后重启服务：

docker-compose down && docker-compose up -d

步骤3：验证Topic创建结果 #

执行以下命令查看已创建的Topic列表：

docker exec -it broker kafka-topics --list --bootstrap-server broker:29092

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