apache-kafka - 将多个 Kafka 键值分组为单个键值

Question

我有一个主题可以捕捉用户正在观看的视频的当前位置。每秒添加事件。

我希望每 30 秒保存一次所有用户的最新视频位置，以限制对 DB 的调用。

有没有办法获取所有用户的最新位置（所有唯一键的最新值），以便我可以执行一次更新？

我尝试使用 KTable，但似乎只能分别获取每个键的最新记录（使用 peek）而不是所有键。

例如，如果我的主题如下所示：

输入主题：

核心价值

User1    1
User1    2
User2    1
User1    3
User2    2
User1    4

作为单个记录的预期输出：

User1    4
User2    2

如果需要，我可以尝试详细说明（我是 Kafka 世界的新手）。

标签： apache-kafkaapache-kafka-streams