我有一个Kafka主题，我在那里存储汽车位置数据。我需要写一个流显示我只有最后4个坐标为每辆车。在Kafka的溪流里我该怎么做？
um6iljoc1#
您可以使用每辆车的窗口聚合，聚合结果是最后4个位置记录的列表。查看文档并举例说明如何进行窗口聚合。https://docs.confluent.io/current/streams/index.htmlhttps://github.com/confluentinc/kafka-streams-examples
1条答案
按热度按时间um6iljoc1#
您可以使用每辆车的窗口聚合，聚合结果是最后4个位置记录的列表。查看文档并举例说明如何进行窗口聚合。
https://docs.confluent.io/current/streams/index.html
https://github.com/confluentinc/kafka-streams-examples