technolords/kafka

Kafka镜像文档

镜像概述和主要用途

该镜像不包含嵌入式Zookeeper，依赖外部已存在的Zookeeper服务，便于实现Kafka集群部署而无需处理Zookeeper的复杂性。镜像集成基于原生JMX信息的健康检查（非通过测试主题发送消息的方式），同时支持Openshift/Kubernetes部署。最新版本基于Kafka 2.0.0构建。

核心功能和特性

• 无嵌入式Zookeeper：依赖外部Zookeeper服务，简化集群部署架构
• JMX健康检查：基于原生JMX信息实现健康状态检测，无需创建测试主题
• 多环境兼容：支持Docker、Openshift及Kubernetes容器化部署
• 版本明确：基于Kafka 2.0.0稳定版本构建

使用场景和适用范围

• 需要部署Kafka集群的生产环境
• 需集成健康检查机制的Kafka服务
• 基于Openshift/Kubernetes的容器化部署场景
• 对Zookeeper管理有独立需求的架构环境

使用方法和配置说明

Docker运行示例

以下示例假设Kafka集群运行在独立网络中：

bash
#!/bin/bash
echo "即将启动Kafka-1容器..."
docker run --detach \
    --name kafka-1 \
    --restart yes \
    --network="kafka-cluster" \
    --ip="192.168.100.100" \
    --volume /var/data/kafka1/config:/etc/kafka/install/config \
    --volume /var/data/kafka1/data:/etc/kafka/install/data \
    --volume /var/data/kafka1/logs:/etc/kafka/install/logs \
    --env "KAFKA.BROKER.ID=1" \
    --env "KAFKA.ZOOKEEPER.CONNECT=192.168.100.10:2181,192.168.100.11:2181,192.168.100.12:2181" \
    --env "KAFKA.WHAT.EVER=sample" \
    technolords/kafka:latest
echo "...启动完成!"

卷配置

镜像定义三个卷用于持久化存储：

• config：配置文件存储路径，容器内路径为/etc/kafka/install/config
• data：主题数据存储路径，容器内路径为/etc/kafka/install/data
• logs：Kafka日志（如log4j日志）存储路径，容器内路径为/etc/kafka/install/logs

注意：所有卷必须设置uid为500的用户所有权，因为Kafka以非root用户运行。

环境变量

环境变量需以KAFKA.为前缀，用于配置Kafka的server.properties文件。若配置项不存在则添加，已存在则更新。例如KAFKA.WHAT.EVER=sample会在配置文件中生成what.ever=sample。

关键环境变量说明：

• KAFKA.BROKER.ID：Broker唯一标识，必须为整数
• KAFKA.ZOOKEEPER.CONNECT：Zookeeper实例列表，格式为host:port[,host:port,...]

更多配置属性可参考：

• https://github.com/apache/kafka/blob/trunk/config/server.properties
• Kafka官方文档 - 配置