Kafdrop是一个用于查看Kafka topic主题和浏览消费者组的Web UI。可以显示Kafka的brokers, topics, partitions, consumers等，并且可以查看topic具体的消息内容。

Github地址：https://github.com/obsidiandynamics/kafdrop

Kafdrop轻量，可以使用docker快速启动或者kubernetes运行（提供了helm方便快速部署）。

Kafdrop 特征

• View Kafka brokers — topic and partition assignments, and controller status
  查看 Kafka 代理 — 主题和分区分配以及控制器状态。
• View topics — partition count, replication status, and custom configuration
  查看主题 — 分区计数、复制状态和自定义配置。
• Browse messages — JSON, plain text, Avro and Protobuf encoding
  浏览消息 — JSON、纯文本、Avro 和 Protobuf 编码。
• View consumer groups — per-partition parked offsets, combined and per-partition lag
  查看使用者组 — 每个分区的停放偏移、组合和每个分区的滞后。
• Create new topics 
  创建新主题。
• View ACLs 
  查看 ACL。
• Support for Azure Event Hubs 
  支持 Azure 事件中心。

Docker快速启动体验

docker run -d --rm -p 9000:9000 \
    -e KAFKA_BROKERCONNECT=<host:port,host:port> \
    -e JVM_OPTS="-Xms32M -Xmx64M" \
    -e SERVER_SERVLET_CONTEXTPATH="/" \
    obsidiandynamics/kafdrop

在 Kubernetes 中运行（使用 Helm Chart）

git clone https://github.com/obsidiandynamics/kafdrop && cd kafdrop

helm upgrade -i kafdrop chart --set image.tag=3.x.x \
    --set kafka.brokerConnect=<host:port,host:port> \
    --set server.servlet.contextPath="/" \
    --set cmdArgs="--message.format=AVRO --schemaregistry.connect=http://localhost:8080" \ #optional
    --set jvm.opts="-Xms32M -Xmx64M"

体验截图

总体预览，主页轻量：

Kafka 具体的broker信息：

Kafka具体topic信息，并且可以查看消费者组：

查看Kafka具体topic的messages：

Kafka消费者组信息，查看消费延迟等信息：