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 Rapply(R record)Apply transformation to therecordand return another record object (which may berecorditself) ornull, corresponding to a map or filter operation respectively.voidclose()Signal that this transformation instance will no longer will be used.ConfigDefconfig()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 therecordand return another record object (which may berecorditself) 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:
closein interfaceAutoCloseable- Specified by:
closein interfaceCloseable
-
-