bulk-cdk-toolkit-extract-cdc: bump debezium shutdown timeout (#50986)

airbytehq · Jan 8, 2025 · 44483fc · 44483fc
1 parent 3dd11e7
commit 44483fc
Showing 1 changed file with 2 additions and 1 deletion.
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,7 +57,8 @@ class DebeziumPropertiesBuilder(private val props: Properties = Properties()) {
         // unless we set the following.
         with("value.converter.replace.null.with.default", "false")
         // Timeout for DebeziumEngine's close() method.
-        with("debezium.embedded.shutdown.pause.before.interrupt.ms", "10000")
+        // We find that in production, substantial time is in fact legitimately required here.
+        with("debezium.embedded.shutdown.pause.before.interrupt.ms", "60000")
         // Unblock CDC syncs by skipping errors caused by unparseable DDLs
         with("schema.history.internal.skip.unparseable.ddl", "true")
     }