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

编程问答 2022-05-24

问题描述

是否可以在连接丢失后重新连接到相同的推送查询？ 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"]}

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）

ksqldb