kafka工具——kafkatool使用_kafka tool怎么用

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最后一次提交的时间