braverhq/kafka

轻量级Kafka开发镜像

本仓库提供基于Confluent Platform 3.0.1/Scala 2.11的Docker化Kafka实例，适用于开发和测试场景。

注意： 此镜像不适合生产环境使用。尝试在生产环境中使用可能导致严重问题。

为什么选择此镜像？

运行Zookeeper和Kafka并配置它们协同工作通常较为繁琐。本镜像通过Supervisord在单个容器中同时运行Zookeeper和Kafka，且预配置为开箱即可协同工作。

运行Kafka

默认情况下，Kafka可通过localhost:9092（PLAIN连接）、localhost:9093（SSL连接）和localhost:9193（SSL + SASL）访问，只需在运行时暴露对应端口：

bash
$ docker run -ti -p 9092:9092 -p 9093:9093 -p 9193:9193 paddycarey/kafka

Kafka提供命令行客户端，可从文件或标准输入读取数据并作为消息发送到Kafka集群（默认每行作为一条消息）。可使用该客户端测试Kafka是否正常工作：

测试生产者

运行生产者并在控制台输入消息发送到服务器：

bash
$ kafka-console-producer.sh --broker-list localhost:9092 --topic "test"
This is a message
This is another message

测试消费者

Kafka还提供命令行消费者，可将消息输出到标准输出：

bash
$ kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic "test" --from-beginning
This is a message
This is another message

在不同终端分别运行上述生产者和消费者命令，在生产者终端输入消息，消费者终端将实时显示消息。

在非localhost上访问Kafka

默认配置下，Kafka可通过localhost访问。若需使用其他主机名访问，可设置KAFKA_ADVERTISED_HOST环境变量：

Docker run方式

bash
$ docker run -ti -e "KAFKA_ADVERTISED_HOST=somehostname" -p 9092:9092 -p 9093:9093 -p 9193:9193 paddycarey/kafka

Docker Compose方式

docker-compose.yml示例：

yaml
kafka:
    image: docker.xuanyuan.run/paddycarey/kafka
    ports:
        - "9092:9092"
        - "9093:9093"
        - "9193:9193"
    environment:
      KAFKA_ADVERTISED_HOST: kafka

consumer:
    build: .
    links:
      - kafka
    command: "python -u consumer.py"

持久化

镜像将日志数据存储在/var/lib/kafka目录。可通过Docker卷持久化该目录，以保留数据超出容器生命周期：

bash
$ docker run -ti -v `pwd`/.data/:/var/lib/kafka -p 9092:9092 -p 9093:9093 -p 9193:9193 paddycarey/kafka

构建镜像

构建Docker镜像命令：

bash
$ docker build -t paddycarey/kafka .

注意： 高级用户可根据需要修改config/kafka/目录下的配置文件，以调整Kafka或Zookeeper的行为。