TombstoneHandler¶
ここでは、Confluent SMT io.confluent.connect.transforms.TombstoneHandler
の使用方法を説明します。
説明¶
tombstone レコードを管理します。tombstone レコードとは、ValueSchema の有無に関係なく、値フィールド全体が null になっているレコードと定義されています。
インストール¶
この変換は Confluent が開発したものであり、Kafka または Confluent Platform にデフォルトで同梱されるものではありません。この変換は、Confluent Hub クライアント を使用してインストールできます。
confluent-hub install confluentinc/connect-transforms:latest
例¶
以下の構成スニペットは、Tombstone
SMT の使用方法と構成方法を示しています。
コネクターは、デフォルトの(warn)動作を使用して tombstone レコードを処理します。この動作では、tombstone レコードは単に無視され、WARN メッセージがログに書き込まれます。
"transforms": "tombstoneHandlerExample",
"transforms.tombstoneHandlerExample.type": "io.confluent.connect.transforms.TombstoneHandler"
コネクターは、ignore 動作を使用して tombstone レコードを処理します。この動作では、tombstone レコードは単に無視され、DEBUG メッセージがログに書き込まれます。
"transforms.tombstoneHandlerExample.type": "io.confluent.connect.transforms.TombstoneHandler",
"transforms.tombstoneHandlerExample.behavior": "ignore",
コネクターは、fail 動作を使用して tombstone レコードを処理します。この動作では、実行は失敗し、DataException
がスローされ、DEBUG メッセージがログに書き込まれます。
"transforms.tombstoneHandlerExample.type": "io.confluent.connect.transforms.TombstoneHandler",
"transforms.tombstoneHandlerExample.behavior": "fail"
ちなみに
その他の例については、マネージド型コネクターの Tombstone Handler を参照してください。
特徴¶
Name | 説明 | 型 | デフォルト | 指定可能な値 | 重要度 |
---|---|---|---|---|---|
behavior |
ignore を設定すると、tombstone レコードは単に無視され、DEBUG メッセージがログに書き込まれます。warn を設定すると、tombstone レコードは単に無視され、WARN メッセージがログに書き込まれます。fail を設定すると、実行は失敗し、DataException がスローされ、DEBUG メッセージがログに書き込まれます。 |
string | warn | [ignore、warn、fail] | 中 |
述語¶
"述語" を使用することにより、一定の条件を満たすレコードのみに変換が適用されるように、変換を構成することができます。述語は変換チェーンで使用することができ、Filter(Apache Kafka) と組み合わせると、条件に基づいて特定のレコードを除外できます。詳細と例については、「述語」を参照してください。