Kafka 可视化工具

使用Kafka的小伙伴，有没有为无法直观地查看 Kafka 的 Topic 里的内容而发过愁呢？

下面推荐给大家一款带有可视化页面的Kafka工具：Kafka Tool （目前最新版本是 2.0.4）

 

Kafka Tool 工具下载

下载地址

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

 

下载界面

不同版本的Kafka对应不同版本的工具，个人使用的是0.11，所以下载的是最新的2.0.4版本

 

如果是Windows，直接点击exe文件，一键安装即可。

 

Kafka Tool 工具使用

1、Kafka 连接配置

1）启动 Kafka Tool

在安装目录下，双击可执行文件 kafkatool.exe，启动 Kafka Tool

 

2）配置 Kafka 连接信息

提示配置相应的连接信息

这个窗口左上角为Add Cluster(添加集群)，但没关系，对应单节点的Kafka实例来说也是可以的，因为这个软件监控的是Zookeeper而不是Kafka，Kafka的集群搭建也是依赖Zookeeper来实现的，所以默认情况下都是直接通过Zookeeper去完成大部分操作。

 

依次填写红框中的信息，点击“Ping” 和 “Test”测试连接情况；测试通过后，点击“Add”进行添加

 

【注意】需要在 C:\Windows\System32\drivers\etc 下的 hosts 文件中，添加入 kafka 的集群域名

例如，添加如下配置（此处需要根据实际情况配置，配置保存后，需要重启KafkaTools才能读取hosts文件中的内容）：

10.10.21.107 kafka1
10.10.21.108 kafka2
10.10.21.109 kafka3

 

2、查看 Kafka 数据

1）查看 Kafka 数据

选择一个Topic --> Data，点击查询即可看到数据（但是Key和Message是二进制的，不能直观的看到具体的消息信息，需要设置展示格式）

Messages选择Newest，表示查看最新的Kafka数据；

结果列表中的每列，通过点击表头，可以按照升序或者降序排序（一般用在时间字段排序，方便查看最新数据）。

 

2）设置 Kafka 数据展示格式

在Tools -->Settings --> Topics，将 Key 和 Message 均设置为String 保存。这样是全局设置，对所有 Topic 均生效。

 

 

如果只是想单独设置某个 Topic，可以选中某个 Topic，在 Properties --> Content Type 中，将显示格式设置为String，点击 Update --> Refresh 即可生效

 

设置后的数据列表如下

 

3）查看具体某一条消息

选中某一个message，点击“Message”查看详情，默认是“Text”格式（如果想看到JSON格式，只需要设置下“View Data As”即可）

 

 

“View Data As”设置为 JSON 后，消息信息格式如下

 

4）过滤查询 Kafka 消息

可以按照Offset（偏移量），Key（消息key），Message（消息主体），Regex（正则表达式）进行单个或者组合查询

 

Logo
Kafka开源项目指南

Kafka开源项目指南提供详尽教程，助开发者掌握其架构、配置和使用，实现高效数据流管理和实时处理。它高性能、可扩展，适合日志收集和实时数据处理，通过持久化保障数据安全，是企业大数据生态系统的核心。

更多推荐

Kafka入门（一） 概述、部署与API的简单使用

Kafka概述、部署与API的简单使用

avatar Kafka开源项目指南

基于canal和kafka同步，实现binlog同步ElasticSearch

文章目录前言elasticsearch 安装canal安装canal-adapter 安装及配置mysql 安装zk及kafaka安装查看效果注意事项前言中间件版本elasticsearch7.5.2canal1.1.4client-adapter1.1.5-alpha-1zookeeper3.4.13kafka2.6.0mysql5.7.31elasticsearch 安装{"settings"

avatar Kafka开源项目指南

基于 Iceberg 的湖仓一体架构在 B 站的实践

背景在B站，每天都有PB级的数据注入到大数据平台，经过离线或实时的ETL建模后，提供给下游的分析、推荐及预测等场景使用。面对如此大规模的数据，如何高效低成本地满足下游数据的分析需求，一直是我们重点的工作方向。我们之前的数据处理流程基本上是这样的：采集端将客户端埋点、服务端埋点、日志、业务数据库等数据收集到HDFS、Kafka等存储系统中，然后通过Hive、Spark、Fl...

avatar Kafka开源项目指南