Merge pull request #795 from Altinity/794-change-logging-level-of-str…

…uct-empty-not-a-valid-cdc-record-+-record-to-info Changed logging level to info for STRUCT EMPTY not a valid CDC record
Altinity · Sep 9, 2024 · ab888d7 · ab888d7
2 parents 73c85cc + 3ea58ed
commit ab888d7
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 1 deletion.
diff --git a/sink-connector-lightweight/docker/log4j2.xml b/sink-connector-lightweight/docker/log4j2.xml
@@ -11,6 +11,10 @@
                 additivity="false">
         <AppenderRef ref="console"/>
         </Logger>-->
+        <Logger name="io.debezium" level="ERROR"
+                additivity="false">
+            <AppenderRef ref="console"/>
+        </Logger>
             <Logger name="com.clickhouse" level="ERROR"
                 additivity="false">
             <AppenderRef ref="console"/>

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
@@ -193,7 +193,7 @@ private ClickHouseStruct processEveryChangeRecord(Properties props, ChangeEvent<
             Struct struct = (Struct) sr.value();
 
             if (struct == null) {
-                log.warn(String.format("STRUCT EMPTY - not a valid CDC record + Record(%s)", record.toString()));
+                log.debug(String.format("STRUCT EMPTY - not a valid CDC record + Record(%s)", record.toString()));
                 return null;
             }
             if (struct.schema() == null) {