Interface Transformation<R extends ConnectRecord<R>>
-
- All Superinterfaces:
AutoCloseable
,Closeable
,Configurable
public interface Transformation<R extends ConnectRecord<R>> extends Configurable, Closeable
Single message transformation for Kafka Connect record types. Connectors can be configured with transformations to make lightweight message-at-a-time modifications.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description R
apply(R record)
Apply transformation to therecord
and return another record object (which may berecord
itself) ornull
, corresponding to a map or filter operation respectively.void
close()
Signal that this transformation instance will no longer will be used.ConfigDef
config()
Configuration specification for this transformation.-
Methods inherited from interface org.apache.kafka.common.Configurable
configure
-
-
-
-
Method Detail
-
apply
R apply(R record)
Apply transformation to therecord
and return another record object (which may berecord
itself) ornull
, corresponding to a map or filter operation respectively. A transformation must not mutate objects reachable from the givenrecord
(including, but not limited to,Headers
,Structs
,Lists
, andMaps
). If such objects need to be changed, a new ConnectRecord should be created and returned. The implementation must be thread-safe.
-
config
ConfigDef config()
Configuration specification for this transformation.
-
close
void close()
Signal that this transformation instance will no longer will be used.- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in interfaceCloseable
-
-