定位

因为似乎可以使用”lenses box”来进行下一个任务，所以在尝试环境搭建的同时，我留下了截图、笔记等。

目标

使用镜头来粗略地操作Kafka集群及其周边机制。

基础设施方面

使用lensesio/box和Docker可以让我创建一个类似实验环境的运行环境。

应用界面 jiè

通过输入 Kafka 主题，可以执行 Streaming SQL 并可视化数据流程。

开始

由于电子邮件中包含了docker run命令，所以请执行。

请沿着这个步骤操作，之后开始移动手指。

通过浏览器访问到管理界面

在所谓的SQL Studio中查看数据。

中央下方有执行结果。

建立一个新的 Kafka 主题

创建数据管道

建立数据管道，将实时事件作为Kafka主题投入。

SQL处理器

使用流式SQL处理实时数据

在手续中定义了流式SQL，据内容显示似乎可以创建速度快艇。

SET defaults.topic.autocreate=true;
INSERT INTO speed_boats
  SELECT STREAM MMSI, Speed, Longitude AS Long, Latitude AS Lat, `Timestamp`
  FROM sea_vessel_position_reports
  WHERE Speed > 10;

消费者监测 zhě cè)

实时数据流

警报设置

略 – 簡單描述劉備的故事