Class AtlasMapSMT<R extends org.apache.kafka.connect.connector.ConnectRecord<R>>

java.lang.Object
io.atlasmap.kafka.smt.AtlasMapSMT<R>
All Implemented Interfaces:
Closeable, AutoCloseable, org.apache.kafka.common.Configurable, org.apache.kafka.connect.transforms.Transformation<R>

public class AtlasMapSMT<R extends org.apache.kafka.connect.connector.ConnectRecord<R>> extends Object implements org.apache.kafka.connect.transforms.Transformation<R>
  • Field Details

    • OVERVIEW_DOC

      public static final String OVERVIEW_DOC
      See Also:
    • CONFIG_DEF

      public static final org.apache.kafka.common.config.ConfigDef CONFIG_DEF
  • Constructor Details

    • AtlasMapSMT

      public AtlasMapSMT()
  • Method Details

    • configure

      public void configure(Map<String,?> props)
      Specified by:
      configure in interface org.apache.kafka.common.Configurable
    • apply

      public R apply(R record)
      Specified by:
      apply in interface org.apache.kafka.connect.transforms.Transformation<R extends org.apache.kafka.connect.connector.ConnectRecord<R>>
    • config

      public org.apache.kafka.common.config.ConfigDef config()
      Specified by:
      config in interface org.apache.kafka.connect.transforms.Transformation<R extends org.apache.kafka.connect.connector.ConnectRecord<R>>
    • close

      public void close()
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface Closeable
      Specified by:
      close in interface org.apache.kafka.connect.transforms.Transformation<R extends org.apache.kafka.connect.connector.ConnectRecord<R>>