diff --git a/pom.xml b/pom.xml index 09e3d59..d91017c 100644 --- a/pom.xml +++ b/pom.xml @@ -26,7 +26,7 @@ io.lenses kafka-connect-smt - 1.1.1-SNAPSHOT + 1.1.3-SNAPSHOT jar diff --git a/src/main/java/io/lenses/connect/smt/header/InsertRollingRecordTimestampHeaders.java b/src/main/java/io/lenses/connect/smt/header/InsertRollingRecordTimestampHeaders.java index e25802c..366fba9 100644 --- a/src/main/java/io/lenses/connect/smt/header/InsertRollingRecordTimestampHeaders.java +++ b/src/main/java/io/lenses/connect/smt/header/InsertRollingRecordTimestampHeaders.java @@ -20,7 +20,7 @@ * * @param the record type */ -class InsertRollingRecordTimestampHeaders> +public class InsertRollingRecordTimestampHeaders> extends InsertRollingTimestampHeaders { @Override diff --git a/src/main/java/io/lenses/connect/smt/header/InsertRollingWallclockHeaders.java b/src/main/java/io/lenses/connect/smt/header/InsertRollingWallclockHeaders.java index 01ebf3e..0895153 100644 --- a/src/main/java/io/lenses/connect/smt/header/InsertRollingWallclockHeaders.java +++ b/src/main/java/io/lenses/connect/smt/header/InsertRollingWallclockHeaders.java @@ -21,7 +21,7 @@ * * @param the record type */ -class InsertRollingWallclockHeaders> +public class InsertRollingWallclockHeaders> extends InsertRollingTimestampHeaders { private Supplier supplier = Instant::now;