Update ClickHouseSinkTask.java

ClickHouse · Feb 10, 2025 · 9039ae2 · 9039ae2
1 parent cd1a080
commit 9039ae2
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/main/java/com/clickhouse/kafka/connect/sink/ClickHouseSinkTask.java b/src/main/java/com/clickhouse/kafka/connect/sink/ClickHouseSinkTask.java
@@ -47,7 +47,9 @@ public void put(Collection<SinkRecord> records) {
             long putStat = System.currentTimeMillis();
             this.proxySinkTask.put(records);
             long putEnd = System.currentTimeMillis();
-            LOGGER.info("Put records: {} in {} ms", records.size(), putEnd - putStat);
+            if (!records.isEmpty()) {
+                LOGGER.info("Put records: {} in {} ms", records.size(), putEnd - putStat);
+            }
         } catch (Exception e) {
             LOGGER.trace("Passing the exception to the exception handler.");
             boolean errorTolerance = clickHouseSinkConfig != null && clickHouseSinkConfig.isErrorsTolerance();