2016-10-20 22 views
0

消費者の高水準APIを使用してKafkaからデータをポーリングしているとき、多くの履歴データが含まれている可能性があります。kafka現在の時刻からデータを取得します

ここからデータを消費して設定し、履歴データをスロー(または放棄)する方法。この問題を解決する方法はありますか?

カフカバージョン:0.9.0.1。

答えて

3

高度なAPIを使用すると、自動オフセット管理が提供され、オフセットを手動で管理する必要はありません。したがって、 'auto.offset.reset'オプションをチェックし、 '最大'に設定してください

関連する問題