Interface Transformation<R extends ConnectRecord<R>>
- All Superinterfaces:
AutoCloseable
,Closeable
,Configurable
Single message transformation for Kafka Connect record types.
Connectors can be configured with transformations to make lightweight message-at-a-time modifications.
-
Method Summary
Modifier and TypeMethodDescriptionApply 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.config()
Configuration specification for this transformation.Methods inherited from interface org.apache.kafka.common.Configurable
configure
-
Method Details
-
apply
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
-