KSQL 查询未通过 REST API 返回响应，即使我正在使用 LIMIT 子句答案

【问题标题】：KSQL query not returning the response via REST API , even I am using LIMIT clauseKSQL 查询未通过 REST API 返回响应，即使我正在使用 LIMIT 子句
【发布时间】：2020-09-02 18:54:29
【问题描述】：

即使我使用的是限制条款，KSQL 查询也不会通过 REST API 返回响应。我的主题包含 1000 条记录，并且我在其上创建了一个 STREAM。如果我使用低于 1000 的限制，那么我会得到响应，但是当我使用限制 1000+ 时，我不会得到任何响应。我们是否应该提前知道记录的数量以便通过 REST 指定限制子句？它是如何工作的？

我尝试过使用 POSTMAN 和 curl 选项，但这些选项都不起作用。但是，从 ksql-cli 相同的查询工作正常。我在这里错过了什么吗？

端点是 /query。

{ "ksql": "SELECT * FROM SAMPLE_TOPIC_1 限制 1200;", “流属性”：{ “ksql.streams.auto.offset.reset”：“最早” } }

注意：这适用于 ksql-cli。

【问题讨论】：

标签： apache-kafka ksqldb

【解决方案1】：

使用 HTTP2 流 API 进行查询可能会更幸运：https://docs.ksqldb.io/en/latest/developer-guide/ksqldb-rest-api/streaming-endpoint/

【讨论】：