【问题标题】:KSQL REST API does not take time to respondKSQL REST API 不需要时间来响应
【发布时间】:2020-05-25 08:36:44
【问题描述】:

我在调用 KSQL Rest 端点执行查询时遇到问题,我的查询是:

select * from stream1 where is = 123 limit 3;

我将其发送到 post 请求的正文中,如下所示:

{ "ksql": "SELECT * FROM stream1 where id = 3 限制 3; ", "流属性": {"ksql.streams.auto.offset.reset": "最早"} }

有时它会在 1 秒内响应,有时会在 5 秒内响应,有时会在 10 秒内响应。

流中有大量数据,只有几条消息;

有什么办法可以解决这个问题,或者我们需要使用postgress,mysql ..来解决这个问题。

【问题讨论】:

  • 您的源主题有多少条消息?如果您从 KSQL CLI 运行查询,您是否发现响应时间存在相同的差异?
  • 主题有 100 条消息,在 KSQL CLI 中响应时间始终为 1-2 秒,但使用 KSQL Rest 端点时存在问题。

标签: apache-kafka ksqldb


【解决方案1】:

您使用的 ksql 版本中的其余端点不打算用作从应用程序层查询流和表的一种方式。它主要是为人类通过 CLI 设计的。

因此,它没有针对您尝试执行的操作类型进行优化。

ksqlDB 的下一个版本 (0.10.x) 将带有一个新的客户端 API,它可以让你做你想做的事。

【讨论】:

    猜你喜欢
    • 2020-02-20
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 2018-01-07
    • 1970-01-01
    • 1970-01-01
    • 2017-09-20
    • 1970-01-01
    相关资源
    最近更新 更多