ksqldb - 最近 X 天注册的所有用户的表格

Question

我有一个从 MySQL 用户表派生的主题，现在想在 ksqldb 中创建一个表，该表始终包含过去 50 天内注册的所有用户。在文档中花了一些时间后，我仍然找不到解决方案。窗口化似乎不起作用，因为据我所知，它仅适用于流-流连接。这种事情甚至可能使用纯 ksql，还是我需要寻找其他解决方案？

谢谢！

标签： ksqldb

Answer 1

我认为 ksqlDB 目前无法做到这一点。这是因为过滤器，例如WHERE DATEDIFF('days', user.registerDate, now()) < 50只会在收到源行时进行评估。

这与标准 SQL dbs 没有太大区别，其中使用类似过滤器构建的物化视图也不会随着时间的推移自动更新。

您可能会使用 Kafka Streams 构建一个系统，该系统可以使用标点符号来驱逐旧条目。

ksqlDB 上的一些增强请求也可能有用：

• 具有基于时间的保留的主题表
• 查看更新