kafka工具——kafkatool使用

kafkatool介绍

  • 快速查看您的所有Kafka集群,包括brokers,topics和consumers
  • 查看分区中消息的内容并添加新消息
  • 查看使用者的偏移量
  • 以漂亮的格式显示JSON和XML消息
  • 添加和删除主题以及其他管理功能
  • 将单个消息从您的分区保存到本地硬盘驱动器
  • 编写自己的插件,使您可以查看自定义数据格式
  • Kafka工具可在Windows,Linux和Mac OS上运行

 

安装使用

下载地址:

http://www.kafkatool.com/download.html

点击可执行文件安装即可

 

使用

1. 连接到kafka服务

 

方法1:通过配置zookeeper信息建立连接

kafka工具——kafkatool使用

 

方法2:通过配置kafka信息建立连接

kafka工具——kafkatool使用

 

 

2.使用说明

连接成功之后我们可以看到该Broker的Topics和Consumers

kafka工具——kafkatool使用

 

从图片中我们看到该kafka Broker中的所有Topic列表和Consumer列表,以及每个Topic的分区,每个分区里面的详细数据

 

Topics

为了方便可读性,建议将消息的key和message设置成String

kafka工具——kafkatool使用

默认是Byte Array格式,我们这里设置成String格式

kafka工具——kafkatool使用

查看某个topic下某个分区的历史消息

kafka工具——kafkatool使用

 

 

Consumers

我们可以看到某个Consumer的详细信息

kafka工具——kafkatool使用

可以看到该Consumer的group里面所有的Topic及分区数量,Start、End、Offset等

Lag可以看到堆积情况(未消费完的数量)

Last Commit最后一次提交的时间