solsson/kafka-prometheus-jmx-exporter

镜像概述

solsson/kafka-prometheus-jmx-exporter镜像专注于Kubernetes环境下Kafka集群的监控需求，支持Prometheus通过JMX Exporter采集Kafka运行指标，助力集群运维管理与性能优化。镜像遵循透明构建原则，直接从源码生成，确保安全性与可追溯性。

核心功能

1. 透明构建：Dockerfile自包含且基于源码构建，无隐藏依赖；
2. 安全稳定：推荐使用镜像SHA值保障部署的安全性与版本稳定性；
3. 生态兼容：支持Kafka生态工具（Zookeeper、Topic管理、Connect、Streams等）；
4. 配置清晰：鼓励显式展示非默认配置，降低初学者上手门槛；
5. 集群适配：原生支持Kubernetes环境，适配Yolean/kubernetes-kafka等集群方案；
6. 多节点友好：避免使用--net=host模式，适配多节点部署场景。

使用场景

• Kubernetes集群中Kafka的实时监控与运维；
• 本地开发测试Kafka相关功能（如Topic创建、消息生产消费）；
• 构建自定义Kafka镜像满足业务特定需求；
• 演示JMX指标采集与Prometheus监控集成。

配置说明

基础使用

默认入口点会列出bin脚本与示例配置，可指定entrypoint调用具体工具：

bash
# 查看kafka-server-start.sh帮助
docker run --entrypoint ./bin/kafka-server-start.sh solsson/kafka-prometheus-jmx-exporter
# 查看kafka-topics.sh帮助
docker run --entrypoint ./bin/kafka-topics.sh solsson/kafka-prometheus-jmx-exporter

配置覆盖

启动Kafka服务时，通过--override参数覆盖默认配置：

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

Log4j配置注意事项

挂载自定义配置时，需注意log4j.properties路径。可通过设置KAFKA_LOG4J_OPTS环境变量指定路径，避免脚本自动猜测错误。

本地构建与测试

本地构建镜像：

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
# 测试消息消费
docker-compose -f build-contracts/docker-compose.yml up test-consume-all