attunitypm/kafdrop

Kafdrop Docker镜像文档

镜像概述

Kafdrop是一个用于查看Kafka主题和浏览消费者组的Web UI工具。它能够显示Kafka集群的关键信息，包括brokers、主题、分区、消费者等，并支持查看消息内容。本镜像基于https://github.com/obsidiandynamics/kafdrop%E9%A1%B9%E7%9B%AE%E5%88%86%E5%8F%89%EF%BC%8C%E6%97%A8%E5%9C%A8%E6%BB%A1%E8%B6%B3%E7%89%B9%E5%AE%9A%E7%8E%AF%E5%A2%83%E9%9C%80%E6%B1%82%EF%BC%8C%E5%A6%82%E6%8F%90%E4%BE%9B%E7%99%BB%E5%BD%95%E5%B1%8F%E5%B9%95%E5%8F%8A%E7%9B%B8%E5%85%B3%E5%87%AD%E6%8D%AE%EF%BC%8C%E6%94%AF%E6%8C%81%E9%80%9A%E8%BF%87%E5%AE%89%E5%85%A8%E5%8F%8D%E5%90%91%E4%BB%A3%E7%90%86%E8%AE%BF%E9%97%AE%E3%80%82

核心功能与特性

• 查看Kafka Brokers：显示主题和分区分配情况，以及控制器状态
• 查看主题：展示分区数量、复制状态和自定义配置
• 浏览消息：支持JSON、纯文本、Avro和Protobuf编码格式
• 查看消费者组：显示每个分区的停放偏移量、合并延迟和每个分区的延迟
• 创建新主题
• 查看ACL（访问控制列表）
• 支持Azure Event Hubs

使用场景与适用范围

Kafdrop适用于Kafka集群的开发和运维人员，主要应用场景包括：

• 监控Kafka集群状态和健康状况
• 查看和分析主题配置及分区信息
• 检查消费者组的偏移量和延迟情况
• 浏览和验证消息内容（支持多种编码格式）
• 管理主题（创建新主题）
• 查看和审计Kafka访问控制列表

使用方法与配置说明

基本部署示例

Docker Run命令

bash
docker run -d -p 9000:9000 \
  -e KAFKA_BROKERS=kafka1:9092,kafka2:9092 \
  --name kafdrop qlikpe/kafdrop

访问Web UI

部署后，通过浏览器访问 http://<主机IP>:9000 即可打开Kafdrop界面。

核心配置参数

安全配置

由于本分支特别支持安全反向代理访问，建议在生产环境中配置HTTPS和适当的身份验证机制，具体配置方式可参考项目GitHub文档。

项目源代码

Kafdrop项目源代码托管于GitHub：https://github.com/Qlik-PE/kafdrop