kafka工具——kafkatool使用
kafkatool介绍
- 快速查看您的所有Kafka集群,包括brokers,topics和consumers
- 查看分区中消息的内容并添加新消息
- 查看使用者的偏移量
- 以漂亮的格式显示JSON和XML消息
- 添加和删除主题以及其他管理功能
- 将单个消息从您的分区保存到本地硬盘驱动器
- 编写自己的插件,使您可以查看自定义数据格式
- Kafka工具可在Windows,Linux和Mac OS上运行
安装使用
下载地址:
http://www.kafkatool.com/download.html
点击可执行文件安装即可
使用
1. 连接到kafka服务
方法1:通过配置zookeeper信息建立连接
方法2:通过配置kafka信息建立连接
2.使用说明
连接成功之后我们可以看到该Broker的Topics和Consumers
从图片中我们看到该kafka Broker中的所有Topic列表和Consumer列表,以及每个Topic的分区,每个分区里面的详细数据
Topics
为了方便可读性,建议将消息的key和message设置成String
默认是Byte Array格式,我们这里设置成String格式
查看某个topic下某个分区的历史消息
Consumers
我们可以看到某个Consumer的详细信息
可以看到该Consumer的group里面所有的Topic及分区数量,Start、End、Offset等
Lag可以看到堆积情况(未消费完的数量)
Last Commit最后一次提交的时间