从KSQL表中读取数据

问题描述 投票:4回答:1

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

我们假设我做了一些流处理并将数据写入KSQL表。现在我想通过Spring应用程序访问这些数据(例如,通过websocket扇出一些实时数据)。我在这里的第一个猜测是使用Spring Kafka并只订阅底层主题。或者我应该使用Kafka Streams?

另一个用例可以是进行流处理并将结果写入Redis存储(例如,对于总是返回当前值的web服务)。这会是什么方法?

谢谢!

apache-kafka apache-kafka-streams apache-kafka-connect spring-kafka ksql
1个回答
6
投票

如果KSQL查询存储在Kafka主题中的结果。因此,您可以通过阅读结果主题来访问第三方应用程序的结果。如果查询结果是Table,则生成的Kafka主题是更改日志主题,这意味着您可以将其读入第三方系统(如Cassandra或Redis)中的表。此表将始终具有最新结果,您可以从Web服务查询它。查看我们的Clickstream演示,我们将结果推送到Elastic进行可视化。可视化值是相应表中的最新值。

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

© www.soinside.com 2019 - 2024. All rights reserved.