solsson/kafka-manager

Kafka Docker镜像说明

镜像概述

本镜像（当前已迁移至solsson/kafka:cmak）是一款设计透明、安全稳定的Kafka Docker镜像，遵循源码直接构建、推荐镜像SHA保障安全等原则，支持Kafka生态工具及Kubernetes集群部署，旨在降低Kafka使用门槛。

核心功能

1. 透明构建：Dockerfile自包含且基于源码构建，可追溯性强。
2. 安全可靠：推荐使用镜像SHA值确保部署的安全性与稳定性。
3. 多工具集成：包含Zookeeper、Topic管理、Connect、Streams等Kafka配套工具。
4. 集群适配：避免--net=host等不适用于多节点的配置，支持Kubernetes集群。
5. 新手友好：鼓励清晰展示非默认配置，帮助初学者快速上手。

使用场景

• 开发环境快速搭建Kafka服务进行功能测试。
• Kubernetes集群中部署高可用Kafka集群。
• 验证Kafka消息生产/消费、压缩算法等特性。
• 集成Kafka监控与日志聚合方案。

配置说明

基本运行

默认运行镜像将列出可用脚本与配置：

bash
docker run docker.xuanyuan.run/solsson/kafka

指定工具运行（如Kafka服务器）：

bash
docker run --entrypoint ./bin/kafka-server-start.sh docker.xuanyuan.run/solsson/kafka

配置覆盖

通过--override参数修改默认配置：

bash
docker run --entrypoint ./bin/kafka-server-start.sh docker.xuanyuan.run/solsson/kafka \
  --override zookeeper.connect=zookeeper:2181 \
  --override log.dirs=/var/lib/kafka/data/topics \
  --override broker.id=0 \
  --override advertised.listener=PLAINTEXT://kafka-0:9092

注意事项

• 挂载自定义配置时，需通过KAFKA_LOG4J_OPTS指定log4j.properties路径。
• 避免用环境变量覆盖配置，以防与Kafka脚本的环境变量冲突。

本地构建与测试

构建镜像

bash
docker build ./kafka

测试验证

使用build-contract测试（需手动解决时序问题）：

bash
# 启动依赖服务
docker-compose -f build-contracts/docker-compose.yml up -d zookeeper kafka-0
# 测试Topic创建
docker-compose -f build-contracts/docker-compose.yml up test-topic-create-1
# 测试Snappy压缩消息
docker-compose -f build-contracts/docker-compose.yml up test-snappy-compression