【发布时间】:2017-12-09 20:10:27
【问题描述】:
我有一个 kafka 主题,我在其中存储汽车位置数据。我需要编写一个流,它只显示每辆车的最后 4 个坐标。 如何在 kafka 流中做到这一点?
【问题讨论】:
标签: apache-kafka apache-kafka-streams kafka-streams-scala
我有一个 kafka 主题,我在其中存储汽车位置数据。我需要编写一个流,它只显示每辆车的最后 4 个坐标。 如何在 kafka 流中做到这一点?
【问题讨论】:
标签: apache-kafka apache-kafka-streams kafka-streams-scala
您可以对每辆车使用窗口聚合,聚合结果是最后 4 个位置记录的列表。查看文档和示例,了解如何进行一般的窗口聚合。
【讨论】: