R- The type of record (must be an implementation of
public interface Transformation<R extends ConnectRecord<R>> extends org.apache.kafka.common.Configurable, Closeable
Connectors can be configured with transformations to make lightweight message-at-a-time modifications.
|Modifier and Type||Method and Description|
Apply transformation to the
Signal that this transformation instance will no longer will be used.
Configuration specification for this transformation.
recordand return another record object (which may be
null, corresponding to a map or filter operation respectively.
A transformation must not mutate objects reachable from the given
(including, but not limited to,
If such objects need to be changed, a new
ConnectRecord should be created and returned.
The implementation must be thread-safe.
record- the record to be transformed; may not be null