kafkasqlapi花费了太多时间

83qze16e  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(185)

我的集群中安装了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秒钟。
我只有一些小的数据集,我不知道是否有一些配置要做的数据快速提取?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题