apache-kafka - 我们可以从历史数据创建 kafka 时间窗口流吗？

Question

我有一些历史数据，每条记录都有时间戳。我想阅读它们并将它们提供给 kafka 主题，并使用 kafka 流以时间窗口的方式处理它们。

现在的问题是，当我创建 kafka 流时间窗口聚合处理器时，我如何告诉 kafka 使用记录中的时间戳字段来创建时间窗口，而不是实时时间？

Answer 1

您需要创建自定义 TimestampExtractor这将从记录本身中提取值 - 在 documentation 中有一个这样的例子, 和 here too .我还找到了this gist这看起来很相关。