Update ClickHouseWriter.java

ClickHouse · Dec 6, 2023 · 32ee7c1 · 32ee7c1
1 parent a50ff84
commit 32ee7c1
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/main/java/com/clickhouse/kafka/connect/sink/db/ClickHouseWriter.java b/src/main/java/com/clickhouse/kafka/connect/sink/db/ClickHouseWriter.java
@@ -464,7 +464,7 @@ protected void doInsertRawBinary(List<Record> records, Table table, QueryIdentif
         }
 
         s3 = System.currentTimeMillis();
-        LOGGER.debug("batchSize: {} data ms: {} send ms: {}", records.size(), s2 - s1, s3 - s2);
+        LOGGER.info("batchSize: {} data ms: {} send ms: {} (QueryId: [{}])", records.size(), s2 - s1, s3 - s2, queryId.getQueryId());
     }
 
 
@@ -530,7 +530,7 @@ protected void doInsertJson(List<Record> records, Table table, QueryIdentifier q
             }
         }
         s3 = System.currentTimeMillis();
-        LOGGER.debug("batchSize: {} data ms: {} send ms: {}", records.size(), s2 - s1, s3 - s2);
+        LOGGER.info("batchSize: {} data ms: {} send ms: {} (QueryId: [{}])", records.size(), s2 - s1, s3 - s2, queryId.getQueryId());
     }
 
     protected void doInsertString(List<Record> records, Table table, QueryIdentifier queryId) throws IOException, ExecutionException, InterruptedException {
@@ -595,7 +595,7 @@ protected void doInsertString(List<Record> records, Table table, QueryIdentifier
             }
         }
         s3 = System.currentTimeMillis();
-        LOGGER.debug("batchSize: {} data ms: {} send ms: {}", records.size(), s2 - s1, s3 - s2);
+        LOGGER.info("batchSize: {} data ms: {} send ms: {} (QueryId: [{}])", records.size(), s2 - s1, s3 - s2, queryId.getQueryId());
     }