DBZ-8499 Make source info versioned

debezium · Dec 10, 2024 · 91fff75 · 91fff75
1 parent 4672413
commit 91fff75
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/src/test/java/io/debezium/connector/informix/SourceInfoTest.java b/src/test/java/io/debezium/connector/informix/SourceInfoTest.java
@@ -16,9 +16,9 @@
 
 import io.debezium.config.CommonConnectorConfig;
 import io.debezium.config.Configuration;
-import io.debezium.connector.AbstractSourceInfoStructMaker;
 import io.debezium.connector.SnapshotRecord;
 import io.debezium.relational.TableId;
+import io.debezium.schema.SchemaFactory;
 
 public class SourceInfoTest {
 
@@ -85,11 +85,12 @@ public void tableIdIsPresent() {
     public void schemaIsCorrect() {
         final Schema schema = SchemaBuilder.struct()
                 .name("io.debezium.connector.informix.Source")
+                .version(SchemaFactory.SOURCE_INFO_DEFAULT_SCHEMA_VERSION)
                 .field("version", Schema.STRING_SCHEMA)
                 .field("connector", Schema.STRING_SCHEMA)
                 .field("name", Schema.STRING_SCHEMA)
                 .field("ts_ms", Schema.INT64_SCHEMA)
-                .field("snapshot", AbstractSourceInfoStructMaker.SNAPSHOT_RECORD_SCHEMA)
+                .field("snapshot", SchemaFactory.get().snapshotRecordSchema())
                 .field("db", Schema.STRING_SCHEMA)
                 .field("sequence", Schema.OPTIONAL_STRING_SCHEMA)
                 .field("ts_us", Schema.OPTIONAL_INT64_SCHEMA)