从KSQL表读取数据

Question

也许这是一个初学者的问题，但是建议使用什么方式读取KSQL中生成的数据？

假设我进行了一些流处理并将数据写入KSQL表。现在，我想通过Spring应用程序访问此数据（例如，通过websocket散布一些实时数据）。我的第一个猜测是使用Spring Kafka并订阅基本主题。还是应该使用Kafka Streams？

另一个用例是进行流处理并将结果写入Redis存储（例如，对于始终返回当前值的Web服务）。这里的方法是什么？

谢谢！

Answer 1

KSQL查询存储在Kafka主题中的结果。因此，您可以通过阅读结果主题从第三方应用程序访问结果。如果查询结果是结果，则TableKafka主题是changelog主题，这意味着您可以将其读入第三方系统（例如Cassandra或Redis）的表中。该表将始终具有最新结果，您可以从Web服务中查询它。查看我们的Clickstream演示，在这里我们将结果推送到Elastic中进行可视化。可视化值是相应表中的最新值。

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