insign/kafka

Kafka Docker镜像文档

镜像概述和主要用途

本镜像提供在Docker中运行Kafka所需的一切组件，包含Kafka和Zookeeper。此外，还包含一个打包的代理，可用于将数据从旧版Kafka 7集群迁移到Docker化的Kafka 8。

核心功能和特性

与其他Kafka Docker镜像相比，本镜像的主要优势在于：

• 无需外部依赖：在同一容器中运行Zookeeper和Kafka，无需依赖外部Zookeeper主机或链接其他容器
• 开箱即用：Zookeeper和Kafka已预先配置为协同工作，无需额外配置

使用场景和适用范围

• 开发环境中快速部署Kafka和Zookeeper
• 需要简化Kafka部署架构的场景
• 从Kafka 7集群迁移数据到新版本Kafka的场景

使用方法和配置说明

基本运行

bash
docker run -p 2181:2181 -p 9092:9092 --env ADVERTISED_HOST=`docker-machine ip \`docker-machine active\`` --env ADVERTISED_PORT=9092 spotify/kafka

环境变量说明：

• ADVERTISED_HOST：Kafka对外通告的主机地址
• ADVERTISED_PORT：Kafka对外通告的端口号，默认为9092

生产者示例

bash
export KAFKA=`docker-machine ip \`docker-machine active\``:9092
kafka-console-producer.sh --broker-list $KAFKA --topic test

消费者示例

bash
export ZOOKEEPER=`docker-machine ip \`docker-machine active\``:2181
kafka-console-consumer.sh --zookeeper $ZOOKEEPER --topic test

运行代理（Kafka 7数据迁移）

代理镜像除了基本参数外，还支持以下新参数：

• CONSUMER_THREADS：从Kafka 7消费数据的线程数
• TOPICS：需要镜像的主题白名单（逗号分隔）
• ZK_CONNECT：源Kafka 7的Zookeeper连接字符串
• GROUP_ID：消费Kafka 7时使用的group.id

运行命令：

bash
docker run -p 2181:2181 -p 9092:9092 \
    --env ADVERTISED_HOST=`boot2docker ip` \
    --env ADVERTISED_PORT=9092 \
    --env CONSUMER_THREADS=1 \
    --env TOPICS=my-topic,some-other-topic \
    --env ZK_CONNECT=kafka7zookeeper:2181/root/path \
    --env GROUP_ID=mymirror \
    spotify/kafkaproxy

包含的镜像

• spotify/kafka：包含Kafka和Zookeeper的Docker镜像，从kafka目录构建
• spotify/kafkaproxy：包含Kafka、Zookeeper和Kafka 7代理的Docker镜像，可配置需要镜像的主题

公共构建地址

• https://registry.hub.docker.com/u/spotify/kafka/
• https://registry.hub.docker.com/u/spotify/kafkaproxy/

从源码构建

bash
docker build -t spotify/kafka kafka/
docker build -t spotify/kafkaproxy kafkaproxy/

待改进事项

• 启动时间未进行特别优化
• 需要更完善的文档