8.2.3. ExtractNewRecordState 変換の設定
ExtractNewRecordState
SMT 設定の詳細をコネクターの設定に追加して、Kafka Connect ソースまたはシンクコネクターで Debezium SMT を設定します。デフォルトの動作を取得するには、.properties
ファイルで以下のように設定します。
transforms=unwrap,... transforms.unwrap.type=io.debezium.transforms.ExtractNewRecordState
Kafka Connect コネクター設定では、Kafka Connect で SMT を適用 transforms=
する順序で複数のコンマ区切りの SMT エイリアスを設定できます。
以下の .properties
例では、複数の ExtractNewRecordState
オプションを設定します。
transforms=unwrap,... transforms.unwrap.type=io.debezium.transforms.ExtractNewRecordState transforms.unwrap.drop.tombstones=false transforms.unwrap.delete.handling.mode=rewrite transforms.unwrap.add.fields=table,lsn
drop.tombstones=false
-
イベントストリームの
DELETE
オペレーションの tombstone レコードを保持します。 delete.handling.mode=rewrite
DELETE
操作では、変更イベントのvalue
フィールドをフラット化して Kafka レコードを編集します。value
フィールドには、フィールドにあるキーと値のペアを直接含めbefore
ます。SMT を追加し__deleted
、に設定します。以下true
に例を示します。"value": { "pk": 2, "cola": null, "__deleted": "true" }
add.fields=table,lsn
-
table
およびlsn
フィールドの change イベントメタデータを単純化された Kafka レコードに追加します。