Overview
オフセットをリセットすることで、コンシューマーグループがメッセージを処理するApache Kafkaトピックパーティション内の位置を手動で変更できます。リセットにより、通常、オフセットがトピックの先頭など、前の位置に移動され、コネクタがその点からのメッセージを再処理します。オフセットを後の位置に移動して、メッセージをスキップすることもできます。
Source Connector オフセットのリセット
MongoDB Kafkaソースコネクタには、 offset.partition.name 構成プロパティを使用してオフセットをリセットする方法が用意されています。詳細については、保存されたオフセットのリセット を参照してください。
Sink Connector オフセットのリセット
MongoDB は、 MongoDB Kafkaシンクコネクタの オフセットのリセット をサポートしていません。ただし、 Apache Kafkaコネクタします。
詳細については、 Confluent ドキュメントのKafkaコンシューマー グループ ツール ページを参照してください。
Considerations
MongoDB KafkaソースコネクタまたはMongoDB Kafkaシンクコネクタのオフセットをリセットする前に、次の点を考慮してください。
オフセットをリセットすると、メッセージがスキップまたは再処理される可能性があるため、データの不整合やデータが失われる可能性があります。この手順は慎重に使用してください。
この手順のコマンドは、 Apache Kafkaでのみ動作し、 MongoDB配置では動作しません。必要な手順は、プロバイダーや構成によって異なる場合があります。Kafkaプロバイダーのドキュメントを確認し、プロバイダーまたは管理者にこの手順が環境に適していることを確認してください。