ksqldb REST API 推送查询 - 重新连接到上次消耗的偏移量 + 1

是否可以在连接丢失后重新连接到相同的推送查询？ terminating 查询有一个 queryId。也可以用于通过 ksqldb REST API 重新连接？

客户端应该从一开始就收到所有记录，以及在连接丢失期间丢失的记录。如果它在偏移 5 处停止，它也应该在偏移 5 之后接收新消息，但不会再次从头开始重放整个主题。理想的情况是对所有消息（记录）进行一次处理。

"POST" "http://<ksqldb-host-name>:8088/query-stream"

{
  "sql": "SELECT * FROM Movies EMIT CHANGES;","properties":{"auto.offset.reset":"earliest"}
}

带有 queryID 的标头响应：

{"queryId":"f91157c7-cd12-407e-a173-5a4cbc398259","columnNames":["TITLE","ID","RELEASE_YEAR"],"columnTypes":["STRING","INTEGER","INTEGER"]}