【发布时间】:2020-05-25 08:36:44
【问题描述】:
我在调用 KSQL Rest 端点执行查询时遇到问题,我的查询是:
select * from stream1 where is = 123 limit 3;
我将其发送到 post 请求的正文中,如下所示:
{ "ksql": "SELECT * FROM stream1 where id = 3 限制 3; ", "流属性": {"ksql.streams.auto.offset.reset": "最早"} }
有时它会在 1 秒内响应,有时会在 5 秒内响应,有时会在 10 秒内响应。
流中有大量数据,只有几条消息;
有什么办法可以解决这个问题,或者我们需要使用postgress,mysql ..来解决这个问题。
【问题讨论】:
-
您的源主题有多少条消息?如果您从 KSQL CLI 运行查询,您是否发现响应时间存在相同的差异?
-
主题有 100 条消息,在 KSQL CLI 中响应时间始终为 1-2 秒,但使用 KSQL Rest 端点时存在问题。
标签: apache-kafka ksqldb