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 Summary
Constructors -
Method Summary
-
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 interfaceorg.apache.kafka.connect.transforms.Transformation<org.apache.kafka.connect.sink.SinkRecord>
-
config
public org.apache.kafka.common.config.ConfigDef config()- Specified by:
config
in interfaceorg.apache.kafka.connect.transforms.Transformation<org.apache.kafka.connect.sink.SinkRecord>
-
close
public void close()- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in interfaceCloseable
- Specified by:
close
in interfaceorg.apache.kafka.connect.transforms.Transformation<org.apache.kafka.connect.sink.SinkRecord>
-
configure
- Specified by:
configure
in interfaceorg.apache.kafka.common.Configurable
-