我的集群中安装了kafka和kafka sql。
我有每秒(10行/秒)到达主题的数据,我想获取过去5分钟内到达的所有数据。
我创建了一个ksql流:
CREATE STREAM test_stream ( name varchar, age int ) WITH (kafka_topic='my_topic', value_format='JSON')
当我向kafka sql api或ksql命令发送简单查询时:
SELECT * FROM test_stream LIMIT 1;
返回结果需要7秒钟。
我只有一些小的数据集,我不知道是否有一些配置要做的数据快速提取?
暂无答案!
目前还没有任何答案,快来回答吧!