Topic数据查询

SQL查询支持对Kafka数据源的表进行抽样查询。

如Kafka topic中的数据生产于不同的时间段，则抽样查询时可能无法一次性采集到不同时间段的数据（一般时间段大于7 天的数据）。此时如果需要查看其它时间段的数据，可以通过修改采样起始时间来实现，设置采样起始时间稍早于该时间段即可查询相应数据。

 

1. 在SQL查询页面左侧的目录区域中，选择Kafka类型数据源时，页面右侧会展示该数据源下所有的表信息，可以通过点击表名快速进入到具体的表信息展示页面。在表信息展示页面，通过图标返回之前的数据源表信息列表页面。

2. 在SQL查询页面左侧的目录区域中，展开Kafka数据源并选择其下的数据表，页面右侧查询区域中会出现该数据源的查询页签。

3. 配置各查询参数，如下所示：

• 分片ID：选择kafka表的分区编号。

• 时间：指定时间，查询该时间点之后的数据。

• 条数：输入用户需要查看的数据量，最大为100。

各参数如不修改，默认按照分片0、当前时间、条数为20查询数据。

4. 单击<抽样>按钮，下方将会显示查询到的数据内容。点击图标，可以刷新查询结果。