diff --git a/src/main/java/com/clickhouse/kafka/connect/sink/ClickHouseSinkTask.java b/src/main/java/com/clickhouse/kafka/connect/sink/ClickHouseSinkTask.java
index e1cf603e..5fbc9d7f 100644
--- 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();