Kafka Tool工具使用
今天介绍一款连接kafka的小工具,可以查看集群信息、topic信息、消费者群组等信息,非常方便。
资源下载:
Kafka Tool 2.0.8资源
我这边kafka环境都采用了SASL方式认证,这里主要介绍下这种模式下工具的配置。kafka的安全认证可以参考我这遍文档:
Kafka安全认证配置
工具安装好后,打开settings设置下topic的消息格式,这里选择String
然后添加集群信息,这里kafka版本感觉默认就行(不选也没报错),填写Zookeeper的地址和端口
第二项Security选择SASL Plaintext
Advanced中Bootstrap servers填写Kafka集群地址,SASL Mechanism填写SCRAM-SHA-256
JAAS Config中可以使用两种方式的用户进行连接,
org.apache.kafka.common.security.scram.ScramLoginModule required username=“用户名” password=“密码”;
org.apache.kafka.common.security.plain.PlainLoginModule required username=“用户名” password=“密码”;
连接成功后,即可查看kafka的一些信息。
查看topic的消息
点击到具体分区,也可以模拟发送消息
查看消费者群组信息,订阅的topic,消费的offset等信息都可以看到