From e6c0867855e5b615f8952e66b1cd2f4c79bc8699 Mon Sep 17 00:00:00 2001 From: Roman Kudryashov Date: Tue, 19 Dec 2023 20:12:21 +0300 Subject: [PATCH] DBZ-7235 Align VitessCloudEventsProvider/Maker with the core components --- .../connector/vitess/converters/VitessCloudEventsMaker.java | 4 ++-- .../vitess/converters/VitessCloudEventsProvider.java | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/src/main/java/io/debezium/connector/vitess/converters/VitessCloudEventsMaker.java b/src/main/java/io/debezium/connector/vitess/converters/VitessCloudEventsMaker.java index 31f9b219..a8512367 100644 --- a/src/main/java/io/debezium/connector/vitess/converters/VitessCloudEventsMaker.java +++ b/src/main/java/io/debezium/connector/vitess/converters/VitessCloudEventsMaker.java @@ -18,8 +18,8 @@ */ public class VitessCloudEventsMaker extends CloudEventsMaker { - public VitessCloudEventsMaker(RecordParser parser, SerializerType contentType, String dataSchemaUriBase) { - super(parser, contentType, dataSchemaUriBase); + public VitessCloudEventsMaker(RecordParser parser, SerializerType contentType, String dataSchemaUriBase, String cloudEventsSchemaName) { + super(parser, contentType, dataSchemaUriBase, cloudEventsSchemaName); } @Override diff --git a/src/main/java/io/debezium/connector/vitess/converters/VitessCloudEventsProvider.java b/src/main/java/io/debezium/connector/vitess/converters/VitessCloudEventsProvider.java index c5649681..3996fef9 100644 --- a/src/main/java/io/debezium/connector/vitess/converters/VitessCloudEventsProvider.java +++ b/src/main/java/io/debezium/connector/vitess/converters/VitessCloudEventsProvider.java @@ -29,7 +29,7 @@ public RecordParser createParser(RecordAndMetadata recordAndMetadata) { } @Override - public CloudEventsMaker createMaker(RecordParser parser, SerializerType contentType, String dataSchemaUriBase) { - return new VitessCloudEventsMaker(parser, contentType, dataSchemaUriBase); + public CloudEventsMaker createMaker(RecordParser parser, SerializerType contentType, String dataSchemaUriBase, String cloudEventsSchemaName) { + return new VitessCloudEventsMaker(parser, contentType, dataSchemaUriBase, cloudEventsSchemaName); } }