14.2. Debezium コネクターでのカスタムコンバーターの使用

前提条件

• カスタムコンバーター Java プログラムがある。

手順

• Debezium コネクターでカスタムコンバーターを使用するには、Java プロジェクトを JAR ファイルにエクスポートし、そのファイルを使用する各 Debezium コネクターの JAR ファイルを含むディレクトリーにコピーします。
  
  たとえば、一般的なデプロイメントでは、Debezium コネクターファイルは Kafka Connect ディレクトリーのサブディレクトリー (/kafka/connect) に保存され、各コネクター JAR は独自のサブディレクトリー (/kafka/connect/debezium-connector-db2、/kafka/connect/debezium-connector-mysql など) に格納されます。コネクターでコンバーターを使用するには、コンバーターの JAR ファイルをコネクターのサブディレクトリーに追加します。

手順

• 以下の必須プロパティーをコネクター設定に追加して、コネクターインスタンスのコンバーターを有効にします。

  converters: <converterSymbolicName> 

  1

  
  <converterSymbolicName>.type: <fullyQualifiedConverterClassName> 

  2

  Expand

  表14.3 コンバーターを有効にするためのコネクター設定プロパティーの説明

  項目	説明
  1	必須の converters プロパティーは、コネクターで使用するコンバーターインスタンスのシンボリック名のコンマ区切りリストを列挙します。このプロパティーに一覧表示される値は、コンバーターに指定する他のプロパティーの値の名前の接頭辞として機能します。
  2	必須の <converterSymbolicName>.type プロパティーは、コンバーターを実装するクラスの名前を指定します。

  Show more

  たとえば、前述の カスタムコンバーターのサンプル では、以下のプロパティーをコネクター設定に追加します。

  converters: isbn
  isbn.type: io.debezium.test.IsbnConverter

• 他のプロパティーをカスタムコンバーターに関連付けるには、プロパティー名の前にコンバーターの記号名を付け、その後にドット (.) を付けます。シンボリック名は、converters プロパティーの値として指定するラベルです。たとえば、前述の isbn コンバーターのプロパティーを追加して、コンバーターコードの configure メソッドに渡す schema.name を指定するには、以下のプロパティーを追加します。

  isbn.schema.name: io.debezium.postgresql.type.Isbn