也许这是一个初学者的问题，但是什么是阅读ksql中生成的数据的推荐方法？
假设我做了一些流处理并将数据写入ksql表。现在我想通过spring应用程序访问这些数据（例如，通过websocket扇出一些实时数据）。我在这里的第一个猜测是使用SpringKafka，只订阅基本主题。或者我应该使用Kafka流？
另一个用例可以是进行流处理并将结果写入redis存储（例如，对于总是返回当前值的webservice）。这里的方法是什么？
谢谢！
也许这是一个初学者的问题，但是什么是阅读ksql中生成的数据的推荐方法？
假设我做了一些流处理并将数据写入ksql表。现在我想通过spring应用程序访问这些数据（例如，通过websocket扇出一些实时数据）。我在这里的第一个猜测是使用SpringKafka，只订阅基本主题。或者我应该使用Kafka流？
另一个用例可以是进行流处理并将结果写入redis存储（例如，对于总是返回当前值的webservice）。这里的方法是什么？
谢谢！
1条答案
按热度按时间6ovsh4lw1#
如果ksql查询存储在kafka主题中，则返回结果。因此，您可以通过读取结果主题来访问第三方应用程序的结果。如果查询结果是
Table产生的kafka主题是一个changelog主题，这意味着您可以将其读入第三方系统（如cassandra或redis）中的表中。此表将始终具有最新结果，您可以从web服务中查询它。查看我们的clickstream演示，我们将结果推送到elastic中进行可视化。可视化值是对应表中的最新值。https://github.com/confluentinc/ksql/tree/master/ksql-clickstream-demo#clickstream-分析