如何从卡夫卡用卡夫卡流通过间隔

Question

我想在卡夫卡流消费者使用读卡夫卡的记录，有读取记录每一个给定的时间间隔的选择读取记录？例如每1分钟？

Answer 1

我不知道我是否正确地理解你的问题。但是，我认为有多种方法（取决于你实际想要达到的目标，而不是从问题中得出）。

1. 使用卡夫卡流DSL（卡夫卡0.10）：使用卡夫卡流（Java流处理库），你可以指定一个窗口聚集为任何规模大小
2. 开拓时间戳（卡夫卡0.10）的翻滚窗口：如果您要使用KafkaConsumer你可以阅读邮件，并通过间隔检查它们的时间戳，块数据
3. 系统基于时间的（所有版本卡夫卡）：刚刚从卡夫卡读取消息，并把传递消息在系统中的时间间隔基地。也就是说，在你处理下一个记录之前，你需要检查你的本地时钟来间隔地发送消息。