Kafka-Streamを使ってKafka-Streamを使ってレコードを読み取る方法

Question

私はKafka-StreamコンシューマでKafkaのレコードを読みたいと思っています。例えば1分ごとに？

Answer 1

私はあなたの質問を正しく理解しているかどうかわかりません。しかし、私は複数のアプローチがあると思います（あなたが実際に何を達成したいのかは、質問からは不明確です）。

1. 使用カフカストリームDSL（カフカ0.10）：あなたの場合：任意のサイズ
2. のタンブリングウィンドウは、タイムスタンプ（カフカ0.10）エクスプロイトとして使用すると、ウィンドウの集約を指定することができますカフカストリーム（Javaストリーム処理ライブラリ）を使用して、 KafkaConsumerを使用したい場合は、メッセージを読んで、タイムスタンプをチェックして、間隔でデータをチャンクすることができます。
3. システム時間ベース（すべてのカフカバージョン）：カフカからのメッセージを読み込み、つまり、次のレコードを処理する前に、ローカルクロックを調べて間隔を空けてメッセージを配置します。