Package org.apache.kafka.connect.transforms

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

    Modifier and Type Method 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.
    ConfigDef config()
    Configuration specification for this transformation.

    Methods inherited from interface org.apache.kafka.common.Configurable

    configure

  • Method Details

    • 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

      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