Kafka SQL查询Topic中消息内容
Kafka Eagle监控系统是一款用来监控Kafka集群的工具,目前更新的版本是v1.4.0,支持管理多个Kafka集群、管理Kafka主题(包含查看、删除、创建等)、消费者组、消费者实例监控、消息阻塞告警、Kafka集群健康状态查看等等。
关于Kafka Eagle 可视化监控工具的安装和配置,可以参考专栏文章:安装和配置Kafka集群开源的可视化监控工具-Kafka Eagle
一,查询Topic 列表以及对应的分区
在Kafka Eagle 控制台,点击左侧Topic/List 菜单项,先查看Topic 列表以及对应Partition 分区信息。
二、查询Topic 中消息内容
在点击左侧Topic/KSQL 菜单项,在Kafka Query SQL 文本框输入SQL 脚本,以test_topic 主题为例。
select * from "test_topic" where "partition" in (0,1,2) limit 10
如下图所示:
正常情况下使用Kafka SQL查询Topic,返回结果如下图所示:
相关推荐
ljcsdn 2020-07-27
woaishanguosha 2020-07-18
qingyuerji 2020-06-14
MojitoBlogs 2020-06-14
MojitoBlogs 2020-06-09
猫咪的一生 2020-06-03
guicaizhou 2020-05-05
猫咪的一生 2020-05-03
jiangkai00 2020-04-15
方新德 2020-04-08
jiangkai00 2020-03-20
那年夏天0 2020-02-22
sweetgirl0 2020-02-21
sweetgirl0 2020-02-09
MrZhangAdd 2020-01-13
jiangkai00 2020-01-12
GoatSucker 2020-01-11
yangyutong00 2019-12-30