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 cd1a080 + 9039ae2 commit 902d2d6Copy full SHA for 902d2d6
src/main/java/com/clickhouse/kafka/connect/sink/ClickHouseSinkTask.java
@@ -47,7 +47,9 @@ public void put(Collection<SinkRecord> records) {
47
long putStat = System.currentTimeMillis();
48
this.proxySinkTask.put(records);
49
long putEnd = System.currentTimeMillis();
50
- LOGGER.info("Put records: {} in {} ms", records.size(), putEnd - putStat);
+ if (!records.isEmpty()) {
51
+ LOGGER.info("Put records: {} in {} ms", records.size(), putEnd - putStat);
52
+ }
53
} catch (Exception e) {
54
LOGGER.trace("Passing the exception to the exception handler.");
55
boolean errorTolerance = clickHouseSinkConfig != null && clickHouseSinkConfig.isErrorsTolerance();
0 commit comments