メッセージの確認応答のメカニズムを持つソースシステム用に提供されています。書き込まれたときに、ソースコネクターが一括または個別にメッセージの確認応答を行うことができます。返されたオフセットに応じて、ソースシステムのオフセットを保存します。実装では、コミットが完了するまでブロックする必要があります。書き込まれた後、各レコードについてソースシステムのオフセットを保存します。この処理を実装する必要はありません。実装方法について説明しました。インターフェイスは大きく異なります。プッシュ型のインターフェイスが使用されるためです。インターフェイスが大きく異なります。同様にシンプルなものです。メソッドに実装の大部分が含まれます。受け付け、必要な変換を実行し、送信先システムに保存します。このプロセスでは、復帰する前に、データがすべて送信先システムに書き込まれたことを保証する必要はありません。実際には、多くの場合、なんらかの内部バッファが役立ちます。プロデューサーのように)、ダウンストリームのデータストアにイベントを挿入するオーバーヘッドを減らすことができます。トピック、パーティション、オフセット、イベントのキーと値)が含まれます。メソッドはオフセットのコミット処理で使用されます。それにより、タスクは障害から復旧して、イベントが失われることのない安全なポイントから再開できます。このメソッドでは、未処理のデータがあれば送信先システムにプッシュし、書き込みに対して確認応答があるまでブロックする必要があります。回のデリバリーを実現するために、オフセット情報を送信先ストアに保存する必要がある場合など、場合によっては役立ちます。最終的な場所にアトミックにコミットすることができます。コンシューマーを使用してデータのポーリングを行います。コネクターのタスクで使用されるコンシューマーインスタンスはいずれも、同じコンシューマーグループに属します。タスクの再構成や障害が発生すると、コンシューマーグループのバランス調整がトリガーされます。バランス調整では、トピックパーティションが新しい一連のタスクに再割り当てされます。コンシューマーのバランス調整の詳細については、「コンシューマー」セクションを参照してください。処理にはコンシューマーセッションのタイムアウトより長い時間がかからないようにする必要があることに注意してください。時間がかかりすぎると、そのコンシューマーはグループから除外され、パーティションのバランス調整がトリガーされ、バランス調整が完了するまで他のすべてのタスクの進行が停止することになります。ベースとなるバランス調整のコールバックと結びついています。割り当てられたパーティションのライターをクローズするために使用されます。よるデータのフェッチが停止された後に呼び出されます。は新しいレコードをタスクに書き込みません。割り当てられたすべてのトピックパーティションにアクセスできます。一般に、すべてのトピックパーティションのライターをクローズし、すべてのトピックのパーティションについてステートを適切に保持できるようにすることをお勧めします。実装において、一部のトピックパーティションのライターをクローズすることもできます。その場合は、目的とするデリバリーの保証が得られるように、バランス調整の前後のステートについて注意深く判断する必要があります。メソッドは、コンシューマーのバランス調整が行われる場合に、新しく割り当てられたパーティション用のライターを作成するために使用されます。よるデータのフェッチが開始される前に呼び出されます。エラーが発生すると、タスクが停止し、失敗のステータスが報告され、対応するコンシューマーインスタンスが終了されます。このコンシューマーのシャットダウンによりバランス調整がトリガーされ、このタスクのトピックパーティションがこのコネクターの他のタスクに再割り当てされます。ID(入力ファイル名)とオフセット(ファイル内の位置)を含めました。正常に停止された場合は、最新のオフセットから再開できるようにします)。このコミット処理はフレームワークによって完全に自動化されていますが、適切な場所から再開できるように入力を遡って適切な位置をシークする方法がわかるのはコネクターのみです。使用して、オフセットデータにアクセスできます。コードを追加して、オフセットが存在する場合はオフセットを読み取り、その位置までシークします。