Merge pull request #565 from Altinity/564-remove-debug-logs

Removed excessive logging statements
Altinity · May 5, 2024 · c6b805a · c6b805a
2 parents e1bc645 + 448aea2
commit c6b805a
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/...c/main/java/com/altinity/clickhouse/debezium/embedded/cdc/DebeziumChangeEventCapture.java b/...c/main/java/com/altinity/clickhouse/debezium/embedded/cdc/DebeziumChangeEventCapture.java
@@ -254,7 +254,7 @@ private ClickHouseStruct processEveryChangeRecord(Properties props, ChangeEvent<
             }
 
             String value = String.valueOf(record.value());
-            log.debug(String.format("Record %s", value));
+            //log.debug(String.format("Record %s", value));
         } catch (Exception e) {
             log.error("Exception processing record", e);
         }

diff --git a/...c/main/java/com/altinity/clickhouse/sink/connector/executor/DebeziumOffsetManagement.java b/...c/main/java/com/altinity/clickhouse/sink/connector/executor/DebeziumOffsetManagement.java
@@ -136,9 +136,9 @@ static synchronized void acknowledgeRecords(List<ClickHouseStruct> batch) throws
             if (record.getCommitter() != null && record.getSourceRecord() != null) {
 
                 record.getCommitter().markProcessed(record.getSourceRecord());
-                log.debug("***** Record successfully marked as processed ****" + "Binlog file:" +
-                        record.getFile() + " Binlog position: " + record.getPos() + " GTID: " + record.getGtid()
-                + "Sequence Number: " + record.getSequenceNumber() + "Debezium Timestamp: " + record.getDebezium_ts_ms());
+//                log.debug("***** Record successfully marked as processed ****" + "Binlog file:" +
+//                        record.getFile() + " Binlog position: " + record.getPos() + " GTID: " + record.getGtid()
+//                + "Sequence Number: " + record.getSequenceNumber() + "Debezium Timestamp: " + record.getDebezium_ts_ms());
 
                 if(record.isLastRecordInBatch()) {
                     record.getCommitter().markBatchFinished();