### 在 CentOS 7.9 系统中使用 Docker 容器部署 Kafka #### 准备工作 在开始之前，需要确认系统已经成功安装并启动了 Docker。如果尚未完成此操作，则可以通过以下命令快速安装 Docker[^3]： ```bash curl -fsSL https://get.docker.com | bash -s docker --mirror Aliyun ``` 完成后，验证 Docker 是否正常运行： ```bash docker version ``` #### 部署 Zookeeper 和 Kafka 由于 Kafka 的消息传递依赖于 Zookeeper，因此需要先启动一个 Zookeeper 实例再启动 Kafka。 以下是具体的步骤说明： 1. **拉取官方镜像** 使用 `docker pull` 命令分别下载 Zookeeper 和 Kafka 的官方镜像。 ```bash docker pull zookeeper:latest docker pull bitnami/kafka:latest ``` 2. **创建网络环境** 创建一个新的自定义桥接网络以便容器之间可以相互通信。 ```bash docker network create kafka-net ``` 3. **启动 Zookeeper 容器** 启动一个名为 `zookeeper-container` 的 Zookeeper 容器，并将其绑定到刚刚创建的网络环境中。 ```bash docker run -d \ --name=zookeeper-container \ --network=kafka-net \ -e ALLOW_ANONYMOUS_LOGIN=yes \ -p 2181:2181 \ zookeeper:latest ``` 4. **启动 Kafka 容器** 接下来启动 Kafka 容器，并指定其连接至已有的 Zookeeper 容器。 ```bash docker run -d \ --name=kafka-container \ --network=kafka-net \ -e KAFKA_BROKER_ID=1 \ -e KAFKA_ZOOKEEPER_CONNECT=zookeeper-container:2181 \ -e ALLOW_PLAINTEXT_LISTENER=yes \ -e KAFKA_ADVERTISED_HOST_NAME=localhost \ -p 9092:9092 \ bitnami/kafka:latest ``` 5. **测试 Kafka 运行状态** 可以进入 Kafka 容器内部执行简单的生产者/消费者测试来验证服务是否正常运行。 生产一条消息： ```bash docker exec -it kafka-container kafka-console-producer.sh --topic test-topic --bootstrap-server localhost:9092 ``` 消费该条消息： ```bash docker exec -it kafka-container kafka-console-consumer.sh --from-beginning --topic test-topic --bootstrap-server localhost:9092 ``` 以上即完成了基于 Docker 的 Kafka 部署过程[^2]。 #### 注意事项 - 若是在服务器环境下远程访问 Kafka，请确保防火墙允许外部流量到达对应的端口 (默认为 9092)[^2]。 - 对于生产环境中的配置调整以及高可用架构设计需进一步深入研究相关文档资料。