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プロバイダーのドキュメントを確認し、プロバイダーまたは管理者にこの手順が環境に適していることを確認してください。