diff --git a/debezium-server-voyager/debezium-server-voyagerexporter/src/main/java/io/debezium/server/ybexporter/DebeziumRecordTransformer.java b/debezium-server-voyager/debezium-server-voyagerexporter/src/main/java/io/debezium/server/ybexporter/DebeziumRecordTransformer.java index f83a58c75..84b66b91b 100644 --- a/debezium-server-voyager/debezium-server-voyagerexporter/src/main/java/io/debezium/server/ybexporter/DebeziumRecordTransformer.java +++ b/debezium-server-voyager/debezium-server-voyagerexporter/src/main/java/io/debezium/server/ybexporter/DebeziumRecordTransformer.java @@ -18,12 +18,14 @@ import java.util.Map; import java.util.HashMap; import org.slf4j.Logger; +import org.slf4j.LoggerFactory; /** * This class ensures of doing any transformation of the record received from debezium * before actually writing that record. */ public class DebeziumRecordTransformer implements RecordTransformer { + private static final Logger LOGGER = LoggerFactory.getLogger(YugabyteDialectConverter.class); private JsonConverter jsonConverter; public DebeziumRecordTransformer(){