我们可以从历史数据创建卡夫卡时间窗口流吗?

Question

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

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

Answer 1

您需要创建一个自定义TimestampExtractor，该将从记录本身中提取值 - 文档中有一个示例，这里也是如此。我还发现这个要点看起来很相关。