rest - Kafka Rest API KSQL 查询永远等待并挂起

Question

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

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

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

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