dylanmei/kafka

docker-kafka

镜像概述

docker-kafka是一个基础的Kafka+Jolokia Docker镜像，未包含环境变量映射，需用户自行提供server.properties配置文件。该镜像提供Kafka服务及Jolokia监控集成，适用于需要自定义Kafka配置的场景。

核心功能与特性

• 集成Kafka服务与Jolokia监控
• 支持用户自定义server.properties配置文件
• 允许通过命令行参数覆盖server.properties中的配置项
• 提供Jolokia API接口用于查询Kafka metrics指标

使用场景

• 开发测试环境中快速部署Kafka服务
• 需要自定义Kafka配置参数的场景
• 需要通过Jolokia监控Kafka运行指标的场景

使用方法

Docker Compose部署

通过Docker Compose快速启动服务：

bash
docker-compose up

验证服务是否正常运行：

bash
# 列出Kafka brokers
kafkacat -L -b localhost:9092

# 发送消息到"hello-logs"主题
echo "hello" | kafkacat -P -b localhost:9092 -t hello-logs

# 从"hello-logs"主题消费消息
kafkacat -C -b localhost:9092 -t hello-logs

使用自定义server.properties

挂载本地server.properties文件启动容器：

bash
docker run --rm -v $PWD/server.properties:/etc/kafka/server.properties docker.xuanyuan.run/dylanmei/kafka

覆盖server.properties配置

通过kafka-server-start.sh命令的--override参数覆盖配置：

bash
docker run --rm docker.xuanyuan.run/dylanmei/kafka bin/kafka-server-start.sh \
  config/server.properties \
  --override broker.id=123 \
  --override zookeeper.connect=example:2181

Jolokia监控

通过Jolokia API查询指标

使用Jolokia API端点查询Kafka metrics，示例：

bash
# 搜索Java.lang类型的MBean
curl -s http://localhost:8778/jolokia/search/java.lang:type=* | jq '.'

# 读取类加载相关指标
curl -s http://localhost:8778/jolokia/read/java.lang:type=ClassLoading | jq '.'

使用J4PSH工具

通过J4PSH（JMX4Perl）工具探索Jolokia：

bash
docker run --rm -it \
  --network=dockerkafka_default \
  docker.xuanyuan.run/jolokia/jmx4perl j4psh --color=no http://kafka-broker:8778/jolokia

注：需确保容器网络正确配置，dockerkafka_default为示例网络名称，需根据实际环境调整。