从KSQL表中读取数据



也许这是一个初学者问题,但是读取在KSQL中产生的数据的推荐方法是什么?

假设我进行一些流处理,然后将数据写入KSQL表。现在,我想通过Spring应用程序访问此数据(例如,通过Websocket驱动一些实时数据)。我的第一个猜测是使用Spring Kafka并订阅基础主题。还是我应该使用kafka流?

另一个用例可能是进行流处理并将结果写入Redis Store(例如,对于始终返回当前值的Web服务)。这里的方法是什么?

谢谢!

如果ksql查询存储在kafka主题中,则结果。因此,您可以通过阅读结果主题访问第三方应用程序的结果。如果查询结果是Table,则结果Kafka主题是一个变更主题,这意味着您可以将其读取到第三方系统(例如Cassandra或redis)中的表中。该表将始终具有最新结果,您可以从Web服务查询它。查看我们的ClickStream演示,将结果推入弹性以进行可视化。可视化值是相应表中的最新值。

https://github.com/confluentinc/ksql/tree/master/ksql-clickstream-demo#clickstream-analysis

相关内容

  • 没有找到相关文章

最新更新