也许这是一个初学者的问题,但是读取KSQL中生成的数据的推荐方法是什么?
我们假设我做了一些流处理并将数据写入KSQL表。现在我想通过Spring应用程序访问这些数据(例如,通过websocket扇出一些实时数据)。我在这里的第一个猜测是使用Spring Kafka并只订阅底层主题。或者我应该使用Kafka Streams?
另一个用例可以是进行流处理并将结果写入Redis存储(例如,对于总是返回当前值的web服务)。这会是什么方法?
谢谢!
如果KSQL查询存储在Kafka主题中的结果。因此,您可以通过阅读结果主题来访问第三方应用程序的结果。如果查询结果是Table
,则生成的Kafka主题是更改日志主题,这意味着您可以将其读入第三方系统(如Cassandra或Redis)中的表。此表将始终具有最新结果,您可以从Web服务查询它。查看我们的Clickstream演示,我们将结果推送到Elastic进行可视化。可视化值是相应表中的最新值。
https://github.com/confluentinc/ksql/tree/master/ksql-clickstream-demo#clickstream-analysis