问KSQL -非流查询
EN

Stack Overflow用户

提问于 2017-12-11 05:36:39

回答 1查看 410关注 0票数 0

是否有方法查询KTABLE中的所有当前条目？我正在尝试使用有效负载执行REST的http请求

{
  "ksql": "SELECT * FROM MY_KTABLE;",
  "streamsProperties": {
      "auto.offset.reset": "earliest"
   }
}

这条小溪正无限期地悬着。文件上说

它相当于一个传统的数据库表，但通过流语义(如窗口)来丰富。

那么，在不需要流的情况下只需要所有当前数据并将KTABLE作为常规缓存表时，是否可以进行常规查询呢？

回答已采纳

发布于 2017-12-11 18:45:07

KTable使用了Kafka的KTable，因此为了访问KTable的当前值，您需要访问流作业的所有实例中的状态存储。在Kafka流中，您可以使用interactive queries实现这一点，但是，我们还不支持KSQL中的交互式查询。

要在KSQL中查看表的当前状态，一个解决办法是使用Kafka将与该表对应的kafka主题推入外部表，例如Postgres表或Cassandra表。此外部表将具有KSQL表的最新值。

票数 1

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/47747002

复制

相似问题

问KSQL -非流查询EN