diff --git a/src/main/java/io/debezium/connector/db2/converters/Db2CloudEventsProvider.java b/src/main/java/io/debezium/connector/db2/converters/Db2CloudEventsProvider.java index e98c0eb..908047e 100644 --- a/src/main/java/io/debezium/connector/db2/converters/Db2CloudEventsProvider.java +++ b/src/main/java/io/debezium/connector/db2/converters/Db2CloudEventsProvider.java @@ -5,10 +5,8 @@ */ package io.debezium.connector.db2.converters; -import org.apache.kafka.connect.data.Schema; -import org.apache.kafka.connect.data.Struct; - import io.debezium.connector.db2.Module; +import io.debezium.converters.recordandmetadata.RecordAndMetadata; import io.debezium.converters.spi.CloudEventsMaker; import io.debezium.converters.spi.CloudEventsProvider; import io.debezium.converters.spi.RecordParser; @@ -26,8 +24,8 @@ public String getName() { } @Override - public RecordParser createParser(Schema schema, Struct record) { - return new Db2RecordParser(schema, record); + public RecordParser createParser(RecordAndMetadata recordAndMetadata) { + return new Db2RecordParser(recordAndMetadata); } @Override diff --git a/src/main/java/io/debezium/connector/db2/converters/Db2RecordParser.java b/src/main/java/io/debezium/connector/db2/converters/Db2RecordParser.java index 8358bc3..636ae5c 100644 --- a/src/main/java/io/debezium/connector/db2/converters/Db2RecordParser.java +++ b/src/main/java/io/debezium/connector/db2/converters/Db2RecordParser.java @@ -7,10 +7,9 @@ import java.util.Set; -import org.apache.kafka.connect.data.Schema; -import org.apache.kafka.connect.data.Struct; import org.apache.kafka.connect.errors.DataException; +import io.debezium.converters.recordandmetadata.RecordAndMetadata; import io.debezium.converters.spi.RecordParser; import io.debezium.data.Envelope; import io.debezium.util.Collect; @@ -29,8 +28,8 @@ public class Db2RecordParser extends RecordParser { CHANGE_LSN_KEY, COMMIT_LSN_KEY); - public Db2RecordParser(Schema schema, Struct record) { - super(schema, record, Envelope.FieldName.BEFORE, Envelope.FieldName.AFTER); + public Db2RecordParser(RecordAndMetadata recordAndMetadata) { + super(recordAndMetadata, Envelope.FieldName.BEFORE, Envelope.FieldName.AFTER); } @Override