Class KafkaMetadataTransform

java.lang.Object
org.apache.iceberg.connect.transforms.KafkaMetadataTransform
All Implemented Interfaces:
Closeable, AutoCloseable, org.apache.kafka.common.Configurable, org.apache.kafka.connect.transforms.Transformation<org.apache.kafka.connect.sink.SinkRecord>

public class KafkaMetadataTransform extends Object implements org.apache.kafka.connect.transforms.Transformation<org.apache.kafka.connect.sink.SinkRecord>
  • Constructor Details

    • KafkaMetadataTransform

      public KafkaMetadataTransform()
  • Method Details

    • apply

      public org.apache.kafka.connect.sink.SinkRecord apply(org.apache.kafka.connect.sink.SinkRecord record)
      Specified by:
      apply in interface org.apache.kafka.connect.transforms.Transformation<org.apache.kafka.connect.sink.SinkRecord>
    • config

      public org.apache.kafka.common.config.ConfigDef config()
      Specified by:
      config in interface org.apache.kafka.connect.transforms.Transformation<org.apache.kafka.connect.sink.SinkRecord>
    • 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<org.apache.kafka.connect.sink.SinkRecord>
    • configure

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