1.下载安装
下载地址：http://www.kafkatool.com/download.html
2.本地windows下hosts配置kafka服务
注意:只有配置好了服务才能通过kafka tool 连通 kafka集群服务器!
cd C:\Windows\System32\drivers\etc
打开编辑hosts文件添加如下:
服务器地址 + 空格 + 别名
47.92.xxx.1x3 kafka-1
139.98.xxx.1x9 kafka-2
139.98.xxx.1x5 kafka-3
注意:这里的三个ip地址就是下面连接kafka tool配置中的Zookeeper Host,填写一个就行!
3.安装好连接kafka tool:
3.1 连接本地kafka:
前提是本地启动了kafka服务,
1.win + r --> cmd 输入: zkServer 打开zookeeper
2.开启kafka: .\bin\windows\kafka-server-start.bat .\config\server.properties
3.消费者: .\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test2020 --from-beginning
4.生产者: .\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test
5. 关闭zookeeper: 进入文件夹bin, .\zkServer.sh stop
6. 关闭 kafka: 进去kafka文件 bin\kafka-server-stop.sh
连接配置如下:
注意:
刚连接上的时候是一个小红点:表示未连接状态
注意:在使用Kafka Tool工具时，查看Topics多了一个topic，就随手删除了。然后问题来了
本地启动kafka报错:
Kafka报错: ERROR Shutdown broker because all log dirs in ... have failed
Kafka服务开始报错：
ERROR Shutdown broker because all log dirs in E:\kafka\kafka_2.11-2.4.0\log have failed (kafka.log.LogManager)
解决:
去报错提示的目录下删除log里topic日志，重启kafka还是报错。原来删除kafka的log目录还不能解决此问题，还得删除zookeeper里zoo.cfg里配置的dataDir目录。
注意：如果是重要数据，一定要备份！！！
原文链接：https://blog.csdn.net/szxiaohe/article/details/103639127
3.2 连接远程kafka 集群服务器
点击 file --> Add Cluster 进行配置
然后:
4.创建和删除topic:
4.1创建topic
4.2删除topic
- 基本使用
kafka环境搭建请参考：CentOS7.5搭建Kafka2.11-1.1.0集群
配置以字符串的形式显示kafka消息体
或者通过如下界面配置
注释：更改完Content Types，要点击Update和Refresh按钮
再次查看kafka的数据：
6.特色功能:
Kafka工具中的浏览器树允许您通过单击几下鼠标来查看和导航Apache Kafka®集群中的对象-代理，主题，分区，使用者。与Kafka群集的连接将保持不变，因此您无需每次都记住或输入它们。无论有多少群集，您都可以快速查看有关所有群集的信息。
查看讯息
您可以在主题的分区中快速查看消息及其键。您可以选择一次查看多少条消息以及从中读取消息的偏移量。您可以查看最早或最新的消息，也可以指定从中开始读取消息的起始偏移量。默认情况下，Kafka工具将以十六进制格式显示您的消息和密钥。但是，如果您的消息是UTF-8编码的字符串，则Kafka工具可以显示实际的字符串，而不是常规的十六进制格式。
以JSON / XML格式查看文本数据
如果基于字符串的数据为JSON或XML格式，则可以在分区下“数据”选项卡的详细信息面板中以漂亮打印的形式查看数据。
查看消费者抵销
浏览器树允许您快速查看Kafka使用者的所有偏移量。该列表将同时显示分区的开始/结束偏移以及每个分区内使用者的偏移。
您还可以查看Apache Storm的Kafka喷口存储的偏移量。阅读更多
保存个人信息
您可以使用分区的“数据”选项卡的详细信息面板中的“保存”按钮将单个消息保存到硬盘驱动器上的文件中。该文件将按原样包含消息的字节。您也可以使用相同的机制保存消息的密钥。
