Fix bug #48497

airbytehq · Nov 22, 2024 · 9e2c36e · 9e2c36e
1 parent eb25860
commit 9e2c36e
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/...toolkits/extract-cdc/src/main/kotlin/io/airbyte/cdk/read/cdc/DebeziumPropertiesBuilder.kt b/...toolkits/extract-cdc/src/main/kotlin/io/airbyte/cdk/read/cdc/DebeziumPropertiesBuilder.kt
@@ -57,6 +57,8 @@ class DebeziumPropertiesBuilder(private val props: Properties = Properties()) {
         with("value.converter.replace.null.with.default", "false")
         // Timeout for DebeziumEngine's close() method.
         with("debezium.embedded.shutdown.pause.before.interrupt.ms", "10000")
+        // Unblock CDC syncs by skipping errors caused by unparseable DDLs
+        with("schema.history.internal.skip.unparseable.ddl", "true")
     }
 
     fun withOffset(): DebeziumPropertiesBuilder = apply {