如何從卡夫卡用卡夫卡流通過間隔

Question

我想在卡夫卡流消費者使用讀卡夫卡的記錄，有讀取記錄每一個給定的時間間隔的選擇讀取記錄？例如每1分鐘？

Answer 1

我不知道我是否正確地理解你的問題。但是，我認爲有多種方法（取決於你實際想要達到的目標，而不是從問題中得出）。

1. 使用卡夫卡流DSL（卡夫卡0.10）：使用卡夫卡流（Java流處理庫），你可以指定一個窗口聚集爲任何規模大小
2. 開拓時間戳（卡夫卡0.10）的翻滾窗口：如果您要使用KafkaConsumer你可以閱讀郵件，並通過間隔檢查它們的時間戳，塊數據
3. 系統基於時間的（所有版本卡夫卡）：剛剛從卡夫卡讀取消息，並把傳遞消息在系統中的時間間隔基地。也就是說，在你處理下一個記錄之前，你需要檢查你的本地時鐘來間隔地發送消息。