org.apache.kafka.connect.transforms

Interface Transformation<R extends ConnectRecord<R>>

All Superinterfaces:

AutoCloseable, Closeable, org.apache.kafka.common.Configurable

public interface Transformation<R extends ConnectRecord<R>>
extends org.apache.kafka.common.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

Modifier and Type	Method and Description
R	apply(R record) Apply transformation to the record and return another record object (which may be record itself) or null, corresponding to a map or filter operation respectively.
void	close() Signal that this transformation instance will no longer will be used.
org.apache.kafka.common.config.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 the record and return another record object (which may be record itself) or null, corresponding to a map or filter operation respectively. A transformation must not mutate objects reachable from the given record (including, but not limited to, Headers, Structs, Lists, and Maps). If such objects need to be changed, a new ConnectRecord should be created and returned. The implementation must be thread-safe.

config

org.apache.kafka.common.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 interface AutoCloseable

Specified by:

close in interface Closeable