apache-kafka - 最佳实践中的 ksqlDB 查询

Question

我目前正在构建一个 ksqlDB 实例，我的目标是以交互模式部署它。

我创建了流和表来为 RocksDB 提供窗口聚合。

我想用 REST API 调用（即 KSQL Rest API 的 Python 包装器）查询缓存，但我不确定这是否是正确的实现方法，因为调用的数量可以达到 1K TPS。

您能否让我知道这是否是反模式，如果是，最佳实践是什么？

谢谢。

Answer 1

你最初的问题对我来说不是很清楚。你不只是请求缓存）

我将假设需要缓存，例如，丰富数据。

在这种情况下，最佳实践是创建一个包含需要丰富和键连接的数据的流。 加入

第二个例子。确实，从外部查询 ksqldb 表是不好的。您可以创建一个将写入主题的流，您的消费者将从该流中写入数据库（可能专门用于缓存 - Redis、Memcached）。您还可以使用接收器连接器，而无需编写使用者。