Kafdrop介绍

Kafdrop 是一个用于查看 Kafka 主题和浏览消费者组的 Web UI。 该工具显示代理、主题、分区、消费者等信息,并且可以预览topic消息。

docker方式部署

1.搜索docker镜像

docker search kafdrop

2.拉取镜像

docker pull obsidiandynamics/kafdrop

3.启动kafdrop

docker run -d -p 9000:9000 --name kafdrop -e KAFKA_BROKERCONNECT=kafka的地址:9092 obsidiandynamics/kafdrop

上述命令中的 KAFKA_BROKERCONNECT 环境变量是指定 Kafka Broker 的连接地址。请根据实际情况更改该地址。

启动后，通过浏览器访问 http://localhost:9000 来使用 Kafdrop 查看和管理 Kafka 集群。效果如下

Docker Compose方式部署

1.在linux服务器的目录下创建一个docker-compose.yml文件并写入如下内容：

version: '3.8'

services:
  kafdrop:
    image: obsidiandynamics/kafdrop
    ports:
      - "9000:9000"
    environment:
      KAFKA_BROKERCONNECT: "kafka:9092" # Kafka Broker 的连接地址
    restart: unless-stopped

2.保存文件后，在终端中进入该项目目录，然后运行以下命令启动 Kafdrop：

docker-compose up -d

3.通过浏览器访问 http://服务器地址:9000即可看到你的kafka broker的主题信息