一、下载
下载地址:http://www.kafkatool.com/download.html
我们的kafka版本是2.11(kafka_2.11-2.0.0-cdh6.1.1),下载kafka tool 2.0.6。
二、安装
双击下载完成的exe图标,傻瓜式完成安装。
三、使用
3.1 连接kafka
执行exe
提示设置kafka集群连接。
依次填写红框中的信息,点击“Ping” 和“Test”测试连接情况,测试通过后,点击“Add”进行添加。
成功之后显示以下界面
3.2 设置Kafka 数据展示格式
配置以字符串的形式显示kafka消息体,否则显示的是二进制的。在Tools -->Settings --> Topics,将 Key 和 Message 均设置为String 保存。这样是全局设置,对所有 Topic 均生效。
如果只是想单独设置某个 Topic,可以选中某个 Topic,在 Properties --> Content Type 中,将显示格式设置为String,点击 Update --> Refresh 即可生效。
3.3 查看数据
选择一个Topic --> Data,点击查询即可看到数据。
3.4 查看某一条具体的数据
选中某一个message,点击“Message”查看详情,默认是“Text”格式。