在前面的内容中,我都是使用命令行的方式来操作管理kafka,下面给大家推荐一个简单便捷的小工具:KafkaTool(目前改名叫做Offset Explorer)。下载地址是:http://www.kafkatool.com/download.html,该工具面向个人使用是免费的,根据自己的操作系统类型直接下载安装即可。

比较遗憾的是笔者在写这篇文档的时候,这个小工具还不能支持kafka 3.0。不过不用着急,随着kafka升级,工具也会不断升级。
如何使用该工具与kafka建立连接,参照下图即可很简单,如果你没有为kafka添加任何的认证机制,在下面的properties配置里面填写完成即可连接kafka服务了。Cluster name:集群名称,kafka集群的唯一标识,随便填写。Kafka Cluster Version:kafka的软件版本,根据实际情况选择;Zookeeper Host: zookeeper服务的主机ip;Zookeeper Port:zookeeper 服务的端口;chroot path :kafka在zookeeper存储的元数据配置的根路径。

在Advanced配置里面填写kafka的broker bootstrap servers地址;我使用单机版测试,所以只填写了一个节点。

如果你使用的是SASL_PLAINTEXT登录认证方式(《kafka安全认证-用户名密码认证》),参考下面3张图的进行配置


使用JAAS方法,填写用户名密码。用户名密码需要参考《kafka安全认证-用户名密码认证》的服务端配置。

连接建立之后,就进入了图形化的用户界面。如果你学习过我前面的文章,相信在这里就不会有任何的障碍了,傻瓜操作。

主要支持的内容:
默认情况下是采用二进制显示消息数据,如果希望显示为字符串,需要对主题配置做如下修改


如果不理解下面这张图表示的概念,去看《消费者组与数据积压》

以上就是我常用的一些功能。
这个工具简单实用,能够代替大部分的手动命令行的执行操作。更多的功能大家自己去探索吧,图形界面很简单的。