We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
2 parents 4544545 + f975e1d commit f0ebd33Copy full SHA for f0ebd33
src/main/java/io/confluent/connect/jdbc/source/JdbcSourceTask.java
@@ -18,7 +18,6 @@
18
import java.sql.SQLNonTransientException;
19
import java.util.TimeZone;
20
import org.apache.kafka.common.config.ConfigException;
21
-import org.apache.kafka.common.utils.SystemTime;
22
import org.apache.kafka.common.utils.Time;
23
import org.apache.kafka.connect.errors.ConnectException;
24
import org.apache.kafka.connect.source.SourceRecord;
@@ -75,7 +74,7 @@ public class JdbcSourceTask extends SourceTask {
75
74
int maxRetriesPerQuerier;
76
77
public JdbcSourceTask() {
78
- this.time = new SystemTime();
+ this.time = Time.SYSTEM;
79
}
80
81
public JdbcSourceTask(Time time) {
0 commit comments