From 9e2c36e3a577f6adcd6433cd4eae5d1ba246f4c1 Mon Sep 17 00:00:00 2001 From: Wenqi Hu Date: Fri, 22 Nov 2024 00:04:04 -0800 Subject: [PATCH] Fix bug #48497 --- .../kotlin/io/airbyte/cdk/read/cdc/DebeziumPropertiesBuilder.kt | 2 ++ 1 file changed, 2 insertions(+) diff --git a/airbyte-cdk/bulk/toolkits/extract-cdc/src/main/kotlin/io/airbyte/cdk/read/cdc/DebeziumPropertiesBuilder.kt b/airbyte-cdk/bulk/toolkits/extract-cdc/src/main/kotlin/io/airbyte/cdk/read/cdc/DebeziumPropertiesBuilder.kt index 97a2aee945f8..543c5387e5d1 100644 --- a/airbyte-cdk/bulk/toolkits/extract-cdc/src/main/kotlin/io/airbyte/cdk/read/cdc/DebeziumPropertiesBuilder.kt +++ b/airbyte-cdk/bulk/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 {