我在调用ksql rest endpoint执行查询时遇到问题,我的查询是:
从stream1中选择其中is=123 limit 3;
我在邮件请求正文中发送如下:
{“ksql”:“selectfrom stream1 where id=3 limit 3;”,“streamsproperties“:{”ksql.streams.auto.offset.reset“:”最早“}}
有时它在1秒内响应,有时它在5秒内响应,有时它在10秒内响应。
流中有大量数据,只有几条消息;
有没有办法解决这个问题或者我们需要使用postgress,mysql。。解决这个问题。
1条答案
按热度按时间idfiyjo81#
您使用的ksql版本中的rest端点不打算用作从应用层查询流和表的方式。它主要是通过cli为人类设计的。
因此,它没有针对您尝试执行的操作类型进行优化。
ksqldb的下一个版本(0.10.x)将附带一个新的客户端api,它可能允许您做您想做的事情。