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
    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
    Signal that this transformation instance will no longer will be used.
    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