From 3b73caedbf71fa8641a379ff0013247900b4591d Mon Sep 17 00:00:00 2001 From: Trinh Van Thoai Date: Tue, 17 Sep 2024 13:33:45 +0700 Subject: [PATCH 1/2] feat: add ServiceLoader for compatible with plugin.discovery=service_load --- .../org.apache.kafka.connect.transforms.Transformation | 6 ++++++ .../io.tabular.iceberg.connect.IcebergSinkConnector | 1 + 2 files changed, 7 insertions(+) create mode 100644 kafka-connect-transforms/src/main/resources/META-INF/services/org.apache.kafka.connect.transforms.Transformation create mode 100644 kafka-connect/src/main/resources/META-INF/services/io.tabular.iceberg.connect.IcebergSinkConnector diff --git a/kafka-connect-transforms/src/main/resources/META-INF/services/org.apache.kafka.connect.transforms.Transformation b/kafka-connect-transforms/src/main/resources/META-INF/services/org.apache.kafka.connect.transforms.Transformation new file mode 100644 index 00000000..6510e2d2 --- /dev/null +++ b/kafka-connect-transforms/src/main/resources/META-INF/services/org.apache.kafka.connect.transforms.Transformation @@ -0,0 +1,6 @@ +io.tabular.iceberg.connect.transforms.CopyValue +io.tabular.iceberg.connect.transforms.DebeziumTransform +io.tabular.iceberg.connect.transforms.DmsTransform +io.tabular.iceberg.connect.transforms.JsonToMapTransform +io.tabular.iceberg.connect.transforms.KafkaMetadataTransform +io.tabular.iceberg.connect.transforms.MongoDebeziumTransform \ No newline at end of file diff --git a/kafka-connect/src/main/resources/META-INF/services/io.tabular.iceberg.connect.IcebergSinkConnector b/kafka-connect/src/main/resources/META-INF/services/io.tabular.iceberg.connect.IcebergSinkConnector new file mode 100644 index 00000000..86a4b624 --- /dev/null +++ b/kafka-connect/src/main/resources/META-INF/services/io.tabular.iceberg.connect.IcebergSinkConnector @@ -0,0 +1 @@ +io.tabular.iceberg.connect.IcebergSinkConnector \ No newline at end of file From 7e6d20376dc4aa50dbfd7667c60d5a0c2b9bd8d0 Mon Sep 17 00:00:00 2001 From: Trinh Van Thoai Date: Tue, 17 Sep 2024 14:36:45 +0700 Subject: [PATCH 2/2] fix: change provider name --- ...gSinkConnector => org.apache.kafka.connect.sink.SinkConnector} | 0 1 file changed, 0 insertions(+), 0 deletions(-) rename kafka-connect/src/main/resources/META-INF/services/{io.tabular.iceberg.connect.IcebergSinkConnector => org.apache.kafka.connect.sink.SinkConnector} (100%) diff --git a/kafka-connect/src/main/resources/META-INF/services/io.tabular.iceberg.connect.IcebergSinkConnector b/kafka-connect/src/main/resources/META-INF/services/org.apache.kafka.connect.sink.SinkConnector similarity index 100% rename from kafka-connect/src/main/resources/META-INF/services/io.tabular.iceberg.connect.IcebergSinkConnector rename to kafka-connect/src/main/resources/META-INF/services/org.apache.kafka.connect.sink.SinkConnector