Skip to content

Commit

Permalink
SMTs ctors visibility
Browse files Browse the repository at this point in the history
Some of the SMTs introduced recently had the ctor visibility set to protected.
  • Loading branch information
stheppi committed Mar 13, 2024
1 parent d16ee97 commit 6d923d2
Show file tree
Hide file tree
Showing 5 changed files with 8 additions and 4 deletions.
2 changes: 1 addition & 1 deletion pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,7 @@

<groupId>io.lenses</groupId>
<artifactId>kafka-connect-smt</artifactId>
<version>1.1.0-SNAPSHOT</version>
<version>1.1.1-SNAPSHOT</version>
<packaging>jar</packaging>

<properties>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@
public class InsertRecordTimestampHeaders<R extends ConnectRecord<R>>
extends InsertTimestampHeaders<R> {

protected InsertRecordTimestampHeaders() {
public InsertRecordTimestampHeaders() {
super(InsertRecordTimestampHeaders.CONFIG_DEF);
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -45,7 +45,7 @@ abstract class InsertRollingTimestampHeaders<R extends ConnectRecord<R>>
"The rolling window type. The allowed values are hours, minutes or seconds.");
private RollingWindowDetails rollingWindowDetails;

protected InsertRollingTimestampHeaders() {
public InsertRollingTimestampHeaders() {
super(CONFIG_DEF);
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -26,6 +26,10 @@ class InsertRollingWallclockHeaders<R extends ConnectRecord<R>>

private Supplier<Instant> supplier = Instant::now;

public InsertRollingWallclockHeaders() {
super();
}

// used solely for testing purposes
void setInstantSupplier(Supplier<Instant> supplier) {
this.supplier = supplier;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,7 @@
public class InsertWallclockHeaders<R extends ConnectRecord<R>> extends InsertTimestampHeaders<R> {
private Supplier<Instant> instantSupplier = Instant::now;

protected InsertWallclockHeaders() {
public InsertWallclockHeaders() {
super(InsertTimestampHeaders.CONFIG_DEF);
}

Expand Down

0 comments on commit 6d923d2

Please sign in to comment.