From 8444fd9750c180ac7f85c105e2d72a57b4c48855 Mon Sep 17 00:00:00 2001 From: Jiri Pechanec Date: Tue, 10 Dec 2024 11:00:15 +0100 Subject: [PATCH] DBZ-8499 Make source info versioned --- .../java/io/debezium/connector/vitess/SourceInfoTest.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/src/test/java/io/debezium/connector/vitess/SourceInfoTest.java b/src/test/java/io/debezium/connector/vitess/SourceInfoTest.java index 03e19af4..94223408 100644 --- a/src/test/java/io/debezium/connector/vitess/SourceInfoTest.java +++ b/src/test/java/io/debezium/connector/vitess/SourceInfoTest.java @@ -17,9 +17,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; import io.debezium.util.Collect; public class SourceInfoTest { @@ -118,11 +118,12 @@ public void keyspaceIsPresent() { public void schemaIsCorrect() { final Schema schema = SchemaBuilder.struct() .name("io.debezium.connector.vitess.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)