From dae8cb3d1d77298dbd30eb9aca6e6bd80375427d Mon Sep 17 00:00:00 2001 From: stheppi Date: Thu, 28 Mar 2024 21:09:05 +0000 Subject: [PATCH] Fix public visibility of rolling timestamp headers --- pom.xml | 2 +- .../connect/smt/header/InsertRollingRecordTimestampHeaders.java | 2 +- .../connect/smt/header/InsertRollingWallclockHeaders.java | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) 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;