カスタムプラグインの作成 - Amazon Managed Streaming for Apache Kafka

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

カスタムプラグインの作成

プラグインは、コネクタロジックを定義するコードを含む AWS リソースです。JAR ファイル (または 1 つ以上の JAR ファイルを含む ZIP ファイル) を S3 バケットにアップロードし、プラグインを作成するときにバケットの場所を指定します。プラグインが作成されると、MSK Connect はその時点で S3 オブジェクトの内容をコピーします。S3 オブジェクトへのリンクは保持されないため、オブジェクトへのそれ以降の変更はプラグインまたはそのコネクタには影響しません。コネクタを作成するときは、MSK Connect で使用するプラグインを指定します。プラグインとコネクタの関係は one-to-manyです。同じプラグインから 1 つ以上のコネクタを作成できます。

注記

カスタムプラグインは更新できません。新しいバージョンのプラグインコードを使用するには、プラグインを参照するすべてのコネクタを削除し、プラグインを削除してから再作成します。

カスタムプラグインの依存関係パッケージ

プラグインに必要なすべての JAR ファイルと依存関係を含めることをお勧めします。コネクタを次のいずれかとしてパッケージ化します。

  • プラグインに必要なすべての JAR ファイルと依存関係を含む ZIP ファイル。

  • プラグインとその依存関係のすべてのクラスファイルを含む単一の uber JAR。

プラグインの依存関係をバンドルしないと、ランタイム環境の可用性や互換性に影響し、予期しないエラーが発生する可能性があります。

コネクタのコードを開発する方法については、Apache Kafka ドキュメントのコネクタ開発ガイドを参照してください。

を使用したカスタムプラグインの作成 AWS マネジメントコンソール

  1. https://console.aws.amazon.com/msk/ で Amazon MSK コンソールを開きます。

  2. 左側のペインの MSK Connect で、Custom plugins (カスタムプラグイン) を選択します。

  3. Create custom plugin (カスタムプラグインの作成) を選択します。

  4. Browse S3 (S3 の参照) を選択します。

  5. S3 バケットのリストで、プラグインの JAR または ZIP ファイルを含むバケットを選択します。

  6. オブジェクトのリストで、プラグインの JAR または ZIP ファイルの左側にあるボックスを選択し、Choose (選択) を選択します。

  7. Create custom plugin (カスタムプラグインの作成) を選択します。

MSK Connect API を使用してカスタムプラグインを作成するには、CreateCustomPluginを参照してください。