solsson/kafka-initutils

Kafka初始化工具镜像（solsson/kafka-initutils）

镜像概述

该镜像为Kafka集群提供初始化工具支持，包含curl和kubectl，适用于Yolean/kubernetes-kafka风格的初始化容器。其设计目标包括透明构建、推荐使用镜像SHA保障安全稳定、支持Kafka相关工具（如Zookeeper、主题管理、Connect等）、鼓励清晰的配置约定，以及适配Kubernetes环境。

核心功能

• 集成curl和kubectl工具，满足Kubernetes环境下Kafka集群初始化需求
• 支持Kafka官方工具集（Zookeeper、主题管理、Connect、Streams等）
• 透明构建流程，直接从源码构建确保可追溯性
• 避免使用--net=host等不适用于多节点环境的配置
• 适配Yolean/kubernetes-kafka等Kubernetes集群部署方案

使用场景

• Kubernetes环境中Kafka集群的初始化容器，执行预启动配置（如创建主题、连接Zookeeper）
• 本地开发测试Kafka集群时的工具支持
• 多节点Kafka集群的配置管理与维护

配置说明

基础使用

默认运行镜像列出bin脚本和示例配置：

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

指定工具查看帮助：

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

配置覆盖

通过--override参数覆盖默认配置：

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

日志配置

挂载自定义配置时需指定log4j路径：

bash
docker run -e KAFKA_LOG4J_OPTS="-Dlog4j.configuration=file:/path/to/log4j.properties" docker.xuanyuan.run/solsson/kafka-initutils

本地构建与测试

构建镜像

bash
docker build ./kafka

测试步骤

bash
# 启动依赖服务
docker-compose -f build-contracts/docker-compose.yml up -d zookeeper kafka-0
# 查看日志
docker-compose -f build-contracts/docker-compose.yml logs zookeeper kafka-0
# 测试主题创建
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
# 测试消息消费
docker-compose -f build-contracts/docker-compose.yml up test-consume-all

仓库名称说明

原仓库包含多个Dockerfile，现已迁移至独立仓库，但保留原名称以避免Docker Hub自动构建中断。遗留Dockerfile可查看：https://github.com/solsson/dockerfiles/tree/misc-dockerfiles