The following provides usage information for the Confluent SMT
Manage tombstone records. A tombstone record is defined as a record with the entire value field being null, whether or not it has ValueSchema.
This transformation is developed by Confluent and does not ship by default with Kafka or Confluent Platform. You can install this transformation via the Confluent Hub Client:
confluent-hub install confluentinc/connect-transforms:latest
The configuration snippets below show how to use and configure the
transforms=tombstoneHandlerExample # Use the default (warn) behavior to handle tombstone records, which # ignores the tombstone silently and writes a WARN message to log. transforms.tombstoneHandlerExample.type=io.confluent.connect.transforms.TombstoneHandler # Use the ignore behavior to handle tombstone records, which ignores # the tombstone silently and writes a DEBUG message to log. transforms.tombstoneHandlerExample.type=io.confluent.connect.transforms.TombstoneHandler transforms.tombstoneHandlerExample.behavior=ignore # Use the fail behavior to handle tombstone records, which fails the # execution, throws a ``DataException``, and writes a DEBUG message to log. transforms.tombstoneHandlerExample.type=io.confluent.connect.transforms.TombstoneHandler transforms.tombstoneHandlerExample.behavior=fail
||If set to
||string||warn||[ignore, warn, fail]||medium|
Transformations can be configured with predicates so that the transformation is applied only to records which satisfy a condition. You can use predicates in a transformation chain and, when combined with the Filter (Apache Kafka), predicates can conditionally filter out specific records. For details and examples, see Predicates.