### 构建 Kafka 集群前的准备 为了在 Windows 上通过 Docker 搭建 Kafka 集群，需先安装并配置好 Docker Desktop。确保已启用 WSL 2 后端支持以获得更好的性能和兼容性。 ### 下载所需镜像 首先，获取 Zookeeper 和 Kafka 的官方镜像： ```bash docker pull wurstmeister/zookeeper docker pull wurstmeister/kafka ``` 上述命令会从 Docker Hub 中下载由 `wurstmeister` 提供的 Zookeeper 及 Kafka 官方镜像[^1]。 ### 创建网络环境 为了让各个容器之间能够顺利通信，建议创建自定义桥接网络: ```bash docker network create kafka-net ``` 此操作建立了一个名为 `kafka-net` 的虚拟网络用于后续组件间的连接。 ### 启动 ZooKeeper 实例 启动单个 ZooKeeper 节点作为整个集群的基础服务之一： ```bash docker run -dit --name zookeeper \ --network kafka-net \ -e ZOOKEEPER_CLIENT_PORT=2181 \ -p 2181:2181 \ wurstmeister/zookeeper ``` 这段脚本指定了外部访问端口以及内部监听地址，并将其加入到之前创建好的网络环境中。 ### 初始化多个 Kafka Broker 对于每一个想要添加至集群中的 Kafka broker ，都需要单独执行如下指令： #### 第一个Broker (broker-0) ```bash docker run -dit --name=kafka-broker-0 \ --network kafka-net \ -e KAFKA_BROKER_ID=0 \ -e KAFKA_ZOOKEEPER_CONNECT=zookeeper:2181 \ -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://localhost:9092 \ -p 9092:9092 \ wurstmeister/kafka ``` #### 第二个Broker (broker-1) ```bash docker run -dit --name=kafka-broker-1 \ --network kafka-net \ -e KAFKA_BROKER_ID=1 \ -e KAFKA_ZOOKEEPER_CONNECT=zookeeper:2181 \ -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://localhost:9093 \ -p 9093:9093 \ wurstmeister/kafka ``` 重复以上过程可以继续增加更多的 Kafka brokers 。注意每次更改 `-e KAFKA_BROKER_ID=` 参数值使其唯一，并调整对外暴露的服务端口号以避免冲突。 ### 使用 Docker Compose 方案简化部署流程 如果希望进一步简化多节点集群的一键化部署，则可以通过编写 YAML 文件的方式实现自动化管理。下面是一个简单的例子展示如何用 `docker-compose.yml` 来描述上面提到的服务结构[^2]: ```yaml version: '3' services: zookeeper: image: wurstmeister/zookeeper ports: - "2181:2181" kafka_broker_0: image: wurstmeister/kafka depends_on: - zookeeper environment: KAFKA_BROKER_ID: 0 KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181 KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://localhost:9092 ports: - "9092:9092" kafka_broker_1: image: wurstmeister/kafka depends_on: - zookeeper environment: KAFKA_BROKER_ID: 1 KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181 KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://localhost:9093 ports: - "9093:9093" ``` 保存文件后，在同一目录下运行 `docker-compose up -d` 即可快速完成全部设置。