dockerkafka/kafka

kafka-docker

Dockerfile for Apache Kafka

该镜像可直接从https://hub.docker.com/r/dockerkafka/kafka/%E8%8E%B7%E5%8F%96%E3%80%82

你可以在https://github.com/DockerKafka/kafka-docker%E6%B5%8F%E8%A7%88%E6%BA%90%E4%BB%A3%E7%A0%81%E3%80%82

镜像概述和主要用途

本镜像提供了Apache Kafka的容器化部署方案，旨在简化Kafka服务的搭建和使用流程。适用于开发、测试及小型生产环境，支持快速部署Kafka集群组件，包括主题管理、消息生产与消费等核心功能。

核心功能和特性

• 基于官方Apache Kafka构建，确保功能完整性
• 支持Kafka服务的快速启动与停止
• 提供主题创建、生产者/消费者连接等基础操作
• 允许通过挂载配置文件自定义Kafka参数
• 可与Zookeeper容器联动，满足Kafka依赖需求

使用场景和适用范围

• 开发环境中快速搭建Kafka测试环境
• 学习Kafka消息队列的基本操作与原理
• 小型项目中部署轻量级Kafka服务
• 需要频繁调整配置的Kafka实验场景

使用方法和配置说明

拉取镜像

sh
$ docker pull dockerkafka/kafka

启动服务器

Kafka依赖Zookeeper，需先启动Zookeeper容器：

sh
$ docker run -d --name kafkadocker_zookeeper_1 dockerkafka/zookeeper

然后启动Kafka容器并链接Zookeeper：

sh
$ docker run -d --name kafkadocker_kafka_1 --link kafkadocker_zookeeper_1:zookeeper dockerkafka/kafka

创建主题

sh
$ docker run -it --rm --link kafkadocker_zookeeper_1:zookeeper dockerkafka/kafka kafka-topics.sh --create --zookeeper zookeeper:2181 --replication-factor 1 --partitions 5 --topic test

连接服务器

注意：无需在意 WARN Property topic is not valid (kafka.utils.VerifiableProperties) 警告，这是一个已知bug KAFKA-1711。

作为生产者连接

连接后将进入消息流模式，每输入一行文本即发送一条消息：

sh
$ docker run -it --rm --link kafkadocker_kafka_1:kafka dockerkafka/kafka kafka-console-producer.sh --broker-list kafka:9092 --topic test

作为消费者连接

连接后将获取所有历史消息，并持续监听新消息：

sh
$ docker run -it --rm --link kafkadocker_zookeeper_1:zookeeper --link kafkadocker_kafka_1:kafka dockerkafka/kafka kafka-console-consumer.sh --zookeeper zookeeper:2181 --topic test --from-beginning

自定义配置

修改配置文件

1. 克隆仓库后，在image/conf目录下可找到默认Kafka配置文件
2. 使用以下命令启动容器并挂载配置目录，以便在主机上修改配置：

sh
$ docker run -it --rm --volume `pwd`/image/conf:/opt/kafka_2.10-0.8.2.1/config kafkadocker/kafka /bin/bash

构建自定义镜像

完成配置修改和测试后，构建自己的镜像：

sh
$ docker build --tag="my-image" .