### 使用 Docker 安装 Kafka 且不依赖 Zookeeper 的完整步骤 以下是使用 Docker 安装 Kafka 且不依赖 Zookeeper 的完整步骤，基于提供的引用内容[^2]以及相关知识进行整合： 1. **准备 Docker Compose 文件** 创建一个名为 `docker-compose.yml` 的文件，并添加以下内容： ```yaml version: '3' services: kafka: image: bitnami/kafka:latest ports: - "9092:9092" environment: - KAFKA_BROKER_ID=1 - KAFKA_CFG_LISTENERS=PLAINTEXT://:9092 - KAFKA_CFG_ADVERTISED_LISTENERS=PLAINTEXT://<宿主机IP>:9092 - KAFKA_CFG_LISTENER_SECURITY_PROTOCOL_MAP=PLAINTEXT:PLAINTEXT - KAFKA_CFG_INTER_BROKER_LISTENER_NAME=PLAINTEXT - KAFKA_CFG_LOG_DIRS=/bitnami/kafka/data - ALLOW_PLAINTEXT_LISTENER=yes volumes: - kafka_data:/bitnami/kafka/data volumes: kafka_data: ``` 在此配置中，Kafka 不依赖 Zookeeper 运行，而是通过内置的 Raft 协议管理元数据[^2]。 2. **启动服务** 在包含 `docker-compose.yml` 文件的目录下运行以下命令以启动 Kafka 服务： ```bash docker-compose up -d ``` 3. **验证 Kafka 是否正常运行** 进入 Kafka 容器并检查其配置是否正确： ```bash docker exec -it kafka bash cat /opt/bitnami/kafka/config/server.properties | grep advertised.listeners ``` 输出应为类似以下内容（确保 IP 地址与宿主机一致）： ``` advertised.listeners=PLAINTEXT://<宿主机IP>:9092 ``` 4. **清理旧数据（如果需要）** 如果在运行过程中遇到问题，可能是旧数据导致配置未生效。可以尝试清理数据并重启服务： ```bash docker-compose down -v docker-compose up -d ``` 5. **测试客户端连接** 确保客户端能够成功连接到 Kafka 服务： - 测试网络连通性： ```bash ping <宿主机IP> telnet <宿主机IP> 9092 ``` - 如果以上命令均无错误，则说明连接正常。 6. **启动生产者和消费者** 进入 Kafka 容器后，可以使用以下命令启动生产者和消费者进行测试： - 启动生产者： ```bash ./kafka-console-producer.sh --broker-list <宿主机IP>:9092 --topic test ``` - 启动消费者： ```bash ./kafka-console-consumer.sh --bootstrap-server <宿主机IP>:9092 --topic test --from-beginning ``` --- ### 注意事项 - `<宿主机IP>` 需要替换为实际的宿主机 IP 地址。 - 如果宿主机 IP 发生变化，请确保更新 `docker-compose.yml` 文件中的 `advertised.listeners` 配置[^2]。 - 在生产环境中，建议进一步优化配置，例如设置更复杂的认证机制和日志策略。 ---