DBZ-7235 Align VitessCloudEventsProvider/Maker with the core components

debezium · Dec 19, 2023 · e6c0867 · e6c0867
1 parent e498185
commit e6c0867
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 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
@@ -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
@@ -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);
     }
 }