Lenses支持Restful API和websockets,但也有一个用户界面。 本节介绍主要功能的基本用法。
Lenses仪表板
Lenses仪表板提供了概述Lenses平台所需的信息。
1,实时绘制在平台上流动的数据
2,主题和状态的数量
3,关键基础设施(broker、zookeeper和 connect)状态
4,纵览Avro模式的数量
5,纵览部署的SQL处理器的数量
6,纵览部署的Kafka连接器的数量
7,纵览活跃消费群体的数量
8,热点(主题)
9,警报
10,审计
管理主题
通过Lenses,你可以通过导航到侧面菜单中的主题视图来创建、删除和更改主题的配置。
该视图显示:
1,流经Kafka集群数据(受到监控)的图表
2,主题列表和每个主题的详细信息
3,创建和删除主题的功能。
创建主题
要创建主题,请选择新建主题按钮并输入所需的详细信息以创建主题。 最低要求是:
1,name
2,partitions
3,replication
另外,您可以通过选择添加配置链接来提供额外配置以覆盖代理默认值。 这也允许设置常见的覆盖,例如重置时间,保留大小和清理策略。
删除主题
要删除主题,请选择该主题的垃圾桶按钮,并确认是否希望Lenses删除该主题。
注意:如果主题有活动消费者, 一旦消费者停止使用, kafka将会删除该主题。
修改主题
要更改现有主题的配置,请选择该主题,然后选择配置选项卡。
查看主题分区
有关主题的详细信息和指标可以在主题视图的“ Paritions”选项卡中看到。 将主题的所有分区的分布信息可视化,并提供每个分区的详细信息。 它还监视和警报同步复制品ISR - 关于具有复制因素的主题。
主题的消费者
Lenses跟踪主题的消费者,查看主题的消费者群体可以在“消费者”选项卡的查看。 这将显示
1,关注此主题的活跃消费者群体
2,消费群中的客户
3,主broker
4,实时更新整个组的消费滞后
5,消费群体的稳定性
查看实时数据
Lenses提供了利用Lenses SQL引擎可视化主题中的实时数据的能力,只需选择该主题,然后将其放入"Live Stream"选项卡。 该视图提供:
1,一个SQL窗口,用于选择要从主题中查看哪些数据
2,能够检查数据
3,暂停并重新启动流。
4,SQL窗口允许你从记录的键和值中选择和过滤字段,有关功能的完整描述请参考Lenses SQL部分。
将鼠标悬停在记录上会自动暂停数据流,以便检查记录。
查看历史数据
Lenses利用Lenses SQL引擎提供了可视化和下载主题历史数据的功能,只需选择主题并选择“ Data”选项卡即可。 该视图提供:
1,一个SQL窗口,用于选择要从主题中查看哪些数据
2,用于滚动数据的偏移滑块
3,数据的树视图
4,类似于数据视图的网格
5,数据的原始JSON视图。
6,SQL窗口允许您从记录的键和值中选择和过滤字段,有关功能的完整描述请参考Lenses SQL部分。