Kafdrop是Apache Kafka的开源Web UI可视化界面
主要功能

1、查看Kafka代理 -主题和分区分配以及控制器状态

2、查看主题 -分区数，复制状态和自定义配置

3、浏览消息 -JSON，纯文本和Avro编码

4、查看消费者组 -每个分区的停放偏移量，合并延迟和每个分区滞后

5、创建新主题

6、查看ACL

一、安装jdk11
kafdrop jdk版本要求jdk11以上，所以先下载安装jdk11

感谢这位博主，我不用去官网下载了
https://www.cnblogs.com/David3290/p/12560114.html

这里有安装教程：
https://blog.csdn.net/weixin_40928253/article/details/83590136

二、安装zookeeper

1. 下载安装包：http://zookeeper.apache.org/releases.html，我选择的是3.6.2最新版本的，下载解压到指定目录（如下）

	D:\JAVA\tools\zookeeper

 
 

 
 
1

2. 在系统变量中添加ZOOKEEPER_HOME

	D:\JAVA\tools\zookeeper\zookeeper-3.6.2

 
 

 
 
1

3. 编辑path系统变量，添加为路径

	%ZOOKEEPER_HOME%\bin;

 
 

 
 
1

4. 将conf下“zoo_sample.cfg”重命名为“zoo.cfg”

5. 在任意文本编辑器（如notepad）中打开zoo.cfg. 找到并编辑

	dataDir=D:\\JAVA\\tools\\zookeeper\\data
	dataLogDir=D:\\JAVA\\tools\\zookeeper\\log

 
 

 
 
1
2

6. 找到并编辑dataDir=C:/dataDir

7. 打开新的cmd，输入zkServer，运行Zookeeper。

8. 命令行提示如下：说明本地Zookeeper启动成功
   

三、安装kafka
官网地址：http://kafka.apache.org/downloads
1.下载https://mirrors.bfsu.edu.cn/apache/kafka/2.6.0/kafka_2.13-2.6.0.tgz，解压为kafka_2.13-2.6.0，

2.进入Kafka配置目录，D:\JAVA\tools\kafka\kafka_2.13-2.6.0\config ,编辑文件“server.properties” 添加自己的日记目录：log.dirs=D:\JAVA\tools\kafka\log 同时打开注释 listeners=PLAINTEXT://:9092

3.在zookeeper的基础上，运行Kafka服务
进入Kafka安装目录，D:\JAVA\tools\kafka\kafka_2.13-2.6.0
切换到命令行窗口，运行kafka。

.\bin\windows\kafka-server-start.bat .\config\server.properties

 
 

 
 
1

运行成功，会有log文件的输出，连接zk的2181端口，启动默认的9092端口

四、kafdrop源码下载

1. 源码地址
   github地址：https://github.com/obsidiandynamics/kafdrop
   git仓 https://github.com/obsidiandynamics/kafdrop.git
2. 在idea打开
   
3. mvn clean package 报错截图
   
   在pom.xml里添加plugin后，刷新maven后，再执行mvn clean package 就会BUILD SUCCESS

			<plugin>
                <groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-surefire-plugin</artifactId>
                <version>2.12.4</version>
                <configuration>
                    <skipTests>true</skipTests>
                </configuration>
            </plugin>

 
 

 
 
1
2
3
4
5
6
7
8

4. 运行kafdrop 包
   提示运行命令
   Running from JAR

java --add-opens=java.base/sun.nio.ch=ALL-UNNAMED \
    -jar target/kafdrop-<version>.jar \
    --kafka.brokerConnect=<host:port,host:port>,...

 
 

 
 
1
2
3

修改后：

java --add-opens=java.base/sun.nio.ch=ALL-UNNAMED -jar kafdrop-3.28.0-SNAPSHOT.jar --kafka.brokerConnect=localhost:9092

 
 

 
 
1

打开命令窗口，进入D:\JAVA\study\IdeaProjects\kafdrop\target
执行上述命令后

5. 可视化页面
   打开：http://localhost:9000
   
   可以选择创建topic 和删除topic
   
   还有其他功能，等你安装部署好后自己点点玩吧~~~