Kafka Rest API KSQL Query 永远等待并挂起

Question

我正在使用从 curl POST 到 ksql 发出的 Kafka REST API 如果我不使用 LIMIT20，它就会挂起。另外，如果我用它来查询表 它再次挂起。 我从 python 脚本中运行它 在这里，我在行时间之间进行查询，因为它是连续且持久的，因此我无法从流中获取最新结果。

data = {"ksql":"SELECT MAX(ROWTIME),TIMESTAMPTOSTRING(ROWTIME, 'yyyy-MM-dd HH:mm:ss'),MYFIRMWAREVERSION,MYBASEMACID,BOOTTS,IMEI,PRODDEVICESERIALNUM,RESETREASON FROM NOV_STREAM WHERE TIMESTAMPTOSTRING(ROWTIME, 'yyyy-MM-dd HH:mm:ss') >= '2018-12-11 00:29:30'AND TIMESTAMPTOSTRING(ROWTIME, 'yyyy-MM-dd HH:mm:ss') <= '2018-12-11 23:29:30' GROUP BY ROWTIME,MYFIRMWAREVERSION,MYBASEMACID,BOOTTS,IMEI,PRODDEVICESERIALNUM,RESETREASON LIMIT 20;","streamsProperties":{"ksql.streams.auto.offset.reset": "earliest","format": "json"}}

Answer 1

这是意料之中的。 KSQL 查询，除非您使用LIMIT，否则是一个连续 流式查询。也就是说，按照设计，它不会自行终止。流和表都是这种情况。

对于表，查询会继续运行，并将在其查询输出中显示对表的任何后续更新。