翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。

MSK Connect ワーカーを理解する

ワーカーは、コネクタロジックを実行する Java 仮想マシン (JVM) プロセスです。各ワーカーは、並列スレッドで実行され、データをコピーする作業を行う一連のタスクを作成します。タスクは状態を保存しないため、復元力のあるスケーラブルな Data Pipeline を提供するために、いつでも開始、停止、または再開できます。スケーリングイベントまたは予期しない障害によるワーカー数の変更は、残りのワーカーによって自動的に検出され、残りのワーカーのセット全体でタスクのバランスを取り直すように調整されます。Connect ワーカーは、Apache Kafka のコンシューマーグループを使用して、調整とリバランスを行います。

コネクタの容量要件が可変であるか、見積もりが難しい場合は、MSKConnect が必要に応じてワーカー数を指定した下限と上限の間でスケーリングできます。または、コネクタロジックを実行するワーカーの正確な数を指定することもできます。詳細については、「コネクタ容量を理解する」を参照してください。

MSK Connect ワーカーが IP アドレスを使用する

MSK Connect ワーカーは、お客様が用意したサブネットで IP アドレスを使用します。各ワーカーは、お客様が用意したサブネットの 1 つの IP アドレスを使用します。特にワーカー数が変動する可能性のあるコネクタを自動スケーリングする場合は、指定された容量を考慮して CreateConnector リクエストに指定されたサブネットに十分な使用可能な IP アドレスがあることを確認する必要があります。

デフォルトのワーカー構成

MSK Connect には、次のデフォルトのワーカー設定が用意されています。

key.converter=org.apache.kafka.connect.storage.StringConverter
value.converter=org.apache.kafka.connect.storage.StringConverter