即使我使用了limit子句,ksql查询也没有通过restapi返回响应。我的主题包含1000条记录,我在上面创建了一个流。如果我使用小于1000的限制,那么我得到了响应,但是当我使用限制1000+时,我没有得到任何响应。我们是否应该事先知道记录的编号,以便通过rest指定限制条款?它是如何工作的?
我试过使用postman,curl选项,但是没有一个是有效的。但是,在ksqlcli中,同样的查询工作正常。我有什么遗漏吗?
端点是/query。
{“ksql”:“select*from sample_topic_1 limit 1200;”,“streamsproperties“:{”ksql.streams.auto.offset.reset“:”最早“}}
注意:这在ksqlcli中运行良好。
1条答案
按热度按时间pn9klfpd1#
使用http2流式api进行查询可能会更幸运:https://docs.ksqldb.io/en/latest/developer-guide/ksqldb-rest-api/streaming-endpoint/