From d9806fcd6912c29718dc6161832280ff2846b0e1 Mon Sep 17 00:00:00 2001
From: harveyyue <yw_yuewei@126.com>
Date: Sun, 10 Mar 2024 16:01:22 +0800
Subject: [PATCH] DBZ-7618 Implement Versioned interfaces in Transformation and
 Converter plugins

---
 .../java/io/debezium/connector/cassandra/Module.java   |  4 ++--
 .../cassandra/transforms/EnvelopeTransformation.java   | 10 +++++++++-
 2 files changed, 11 insertions(+), 3 deletions(-)

diff --git a/core/src/main/java/io/debezium/connector/cassandra/Module.java b/core/src/main/java/io/debezium/connector/cassandra/Module.java
index 60a93a95..ec8f2178 100644
--- a/core/src/main/java/io/debezium/connector/cassandra/Module.java
+++ b/core/src/main/java/io/debezium/connector/cassandra/Module.java
@@ -5,10 +5,10 @@
  */
 package io.debezium.connector.cassandra;
 
-import java.util.Properties;
-
 import io.debezium.util.IoUtil;
 
+import java.util.Properties;
+
 /**
  * Information about this module.
  */
diff --git a/core/src/main/java/io/debezium/connector/cassandra/transforms/EnvelopeTransformation.java b/core/src/main/java/io/debezium/connector/cassandra/transforms/EnvelopeTransformation.java
index c77fc2d3..ef21d91c 100644
--- a/core/src/main/java/io/debezium/connector/cassandra/transforms/EnvelopeTransformation.java
+++ b/core/src/main/java/io/debezium/connector/cassandra/transforms/EnvelopeTransformation.java
@@ -7,7 +7,9 @@
 
 import java.util.Map;
 
+import io.debezium.connector.cassandra.Module;
 import org.apache.kafka.common.config.ConfigDef;
+import org.apache.kafka.connect.components.Versioned;
 import org.apache.kafka.connect.connector.ConnectRecord;
 import org.apache.kafka.connect.data.Struct;
 import org.apache.kafka.connect.transforms.Transformation;
@@ -16,11 +18,12 @@
 import io.debezium.connector.cassandra.Record;
 import io.debezium.data.Envelope;
 import io.debezium.transforms.SmtManager;
+import io.debezium.util.VersionParser;
 
 /**
  * This SMT allows the Cassandra connector to emit events in accordance with {@link Envelope}.
  */
-public class EnvelopeTransformation<R extends ConnectRecord<R>> implements Transformation<R> {
+public class EnvelopeTransformation<R extends ConnectRecord<R>> implements Transformation<R>, Versioned {
 
     private SmtManager<R> smtManager;
 
@@ -77,4 +80,9 @@ public void configure(Map<String, ?> props) {
         final Configuration config = Configuration.from(props);
         smtManager = new SmtManager<>(config);
     }
+
+    @Override
+    public String version() {
+        return Module.version();
+    }
 }