零、定制app开发主流可视化工具有两种
①定制app开发安装在本地的服务，定制app开发通过网络连接kafka拉取数据并展示 比如：offsetexplorer 应用
②安装在服务器上应用，通过服务器自行拉取代码，对外提供Web，查看kafka的状态及数据。比如：kafdrop应用
一、本地服务 offsetexplorer
1、去kafkatool官网下载Offset Explorer，可以安装windows版本或者linux版本
下载安装
2、启动配置
后续就可以查看topic数据
修改文字类型如图
就可以正常看到数据了
二、Web服务 kafdrop
1、主要功能：
1、查看代理 -主题和分区分配以及控制器状态
2、查看主题 -分区数，复制状态和自定义配置
3、浏览消息 -，纯文本和Avro编码
4、查看消费者组 -每个分区的停放偏移量，合并延迟和每个分区滞后
5、创建新主题
6、查看ACL
2、安装步骤
①安装jdk11
②安装zookeeper
③安装kafka
④kafdrop源码下载
1、源码地址：github地址：
git仓
2、IDEA中使用maven打包成jar包
3、启动jar包带着以下命令
java --add-opens=java.base/sun.nio.ch=ALL-UNNAMED -jar kafdrop-3.29.0.jar --kafka.brokerConnect=1.2.3.4:9092
4、启动命令
startup.sh
java --add-opens=java.base/sun.nio.ch=ALL-UNNAMED -jar kafdrop-3.29.0.jar --kafka.brokerConnect=1.2.3.4:9092restart.sh
- ps -ef | grep kafdrop-3.29.0.jar | grep -v grep | awk '{print $2}' | xargs kill -9
- rm -rf nohup.out
- nohup ./startup.sh > nohup.out &
3、启动完成后
页面访问 1.2.3.4:9000 可以看到kafka集群页面。可以创建topic，删除topic，查看数据，查看分区等操作
三、kafka常用排错命令
kafka-topics.sh --create --bootstrap-server 1.2.3.4:9092 --replication-factor 3 --partitions 3 --topic test
kafka-topics.sh --list --bootstrap-server 1.2.3.4:9092
./kafka-consumer-groups.sh --bootstrap-server 1.2.3.4:9092 --list 查询group列表
./kafka-consumer-groups.sh --bootstrap-server 1.2.3.4:9092 --describe --group test-group 查询group消费者情况
上篇文章：从零开始 kafka集群部署，拒绝挖坑，每一步都经过本人调试成功
kafka简介与集群部署安装（一）kafka使用+集成Java(二)
kafka+websocket示例(三)
完成前三步之后，后续就可以根据业务来定制不同的功能了，
接下来将扩展websocket功能
SpringBoot+websocket构造聊天室(四)
第六步：kafka实现消息队列 简单应用
第七步：kafka工具整理