Skip to content

Commit ce4ecec

Browse files
committed
remove unsupported automatic flush config
1 parent 385d7f2 commit ce4ecec

File tree

1 file changed

+2
-1
lines changed
  • airbyte-integrations/connectors/source-postgres/src/main/kotlin/io/airbyte/integrations/source/postgres/cdc

1 file changed

+2
-1
lines changed

airbyte-integrations/connectors/source-postgres/src/main/kotlin/io/airbyte/integrations/source/postgres/cdc/ReplicationSlotManager.kt

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -44,7 +44,8 @@ class ReplicationSlotManager(
4444
.withSlotName("\"${cdcConfig.replicationSlot}\"")
4545
.withSlotOption("proto_version", 1)
4646
.withSlotOption("publication_names", cdcConfig.publication)
47-
.withAutomaticFlush(false)
47+
// Needed for DBZ 3.3+ with PgJDBC 42.7.7+
48+
//.withAutomaticFlush(false)
4849
.apply {
4950
val serverVersionStr = conn.parameterStatuses["server_version"]
5051
if (serverVersionStr == null) {

0 commit comments

Comments
 (0)