dpchu/kafka

Kafka-Zookeeper 一体化Docker镜像

镜像概述

本镜像将Apache Kafka和Apache Zookeeper整合到单个Docker容器中，提供一站式的分布式消息系统部署方案。通过整合两个核心组件，简化了传统Kafka部署中需分别配置Zookeeper和Kafka的复杂流程，特别适合快速启动和简化环境配置。

核心功能与特性

• 一体化部署：无需单独部署Zookeeper，Kafka服务直接与内置Zookeeper集成
• 简化配置：减少跨服务网络配置，降低部署复杂度
• 快速启动：单容器启动即可完成Kafka消息系统的完整部署
• 轻量级设计：基于精简基础镜像，优化资源占用
• 兼容性保障：内置匹配版本的Kafka和Zookeeper，避免版本兼容性问题

使用场景与适用范围

• 开发环境：快速搭建本地Kafka开发环境，无需复杂配置
• 测试验证：在CI/CD流程中作为集成测试环境，验证消息处理逻辑
• 学习与演示：用于Kafka功能学习、教学演示或小型原型验证
• 小型项目：适用于流量较小的内部系统或小型应用的消息传递需求

使用方法与配置说明

基本启动命令

bash
docker run -d -p 2181:2181 -p 9092:9092 --name kafka-zookeeper [镜像名称]

环境变量配置

自定义配置示例

bash
docker run -d \
  -p 2181:2181 \
  -p 9092:9092 \
  -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.1.100:9092 \
  -e KAFKA_BROKER_ID=1 \
  -v /host/zookeeper-data:/var/lib/zookeeper \
  -v /host/kafka-logs:/var/lib/kafka/logs \
  --name kafka-zookeeper [镜像名称]

Docker Compose配置

yaml
version: '3'
services:
  kafka-zookeeper:
    image: [镜像名称]
    ports:
      - "2181:2181"
      - "9092:9092"
    environment:
      - KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://kafka-zookeeper:9092
      - KAFKA_BROKER_ID=0
    volumes:
      - zookeeper-data:/var/lib/zookeeper
      - kafka-logs:/var/lib/kafka/logs
    restart: unless-stopped

volumes:
  zookeeper-data:
  kafka-logs:

访问验证

1. 连接Zookeeper：

bash
docker exec -it kafka-zookeeper zookeeper-shell localhost:2181

2. 创建Kafka主题：

bash
docker exec -it kafka-zookeeper kafka-topics.sh --create --topic test-topic --bootstrap-server localhost:9092 --partitions 1 --replication-factor 1

3. 发送测试消息：

bash
docker exec -it kafka-zookeeper kafka-console-producer.sh --topic test-topic --bootstrap-server localhost:9092

4. 消费测试消息：

bash
docker exec -it kafka-zookeeper kafka-console-consumer.sh --topic test-topic --bootstrap-server localhost:9092 --from-beginning

注意事项

• 本镜像适用于开发、测试和小型生产环境，大规模生产环境建议采用Kafka与Zookeeper分离部署的架构
• 持久化数据需通过挂载卷实现，避免容器重启导致数据丢失
• 如需跨主机访问，需正确配置KAFKA_ADVERTISED_LISTENERS为可外部访问的地址
• 高可用性场景下，建议使用Kafka集群模式而非单容器部署