0
消費者の高水準APIを使用してKafkaからデータをポーリングしているとき、多くの履歴データが含まれている可能性があります。kafka現在の時刻からデータを取得します
ここからデータを消費して設定し、履歴データをスロー(または放棄)する方法。この問題を解決する方法はありますか?
カフカバージョン:0.9.0.1。
消費者の高水準APIを使用してKafkaからデータをポーリングしているとき、多くの履歴データが含まれている可能性があります。kafka現在の時刻からデータを取得します
ここからデータを消費して設定し、履歴データをスロー(または放棄)する方法。この問題を解決する方法はありますか?
カフカバージョン:0.9.0.1。
高度なAPIを使用すると、自動オフセット管理が提供され、オフセットを手動で管理する必要はありません。したがって、 'auto.offset.reset'オプションをチェックし、 '最大'に設定してください