From 41dfd4f024caa432feb7deef89659108ae421fe6 Mon Sep 17 00:00:00 2001 From: Kaushik Iska Date: Fri, 20 Oct 2023 12:01:10 -0400 Subject: [PATCH] for eventhub disable commit lock (#546) --- flow/connectors/postgres/cdc.go | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/flow/connectors/postgres/cdc.go b/flow/connectors/postgres/cdc.go index 6130094cd7..e8137381b1 100644 --- a/flow/connectors/postgres/cdc.go +++ b/flow/connectors/postgres/cdc.go @@ -317,7 +317,11 @@ func (p *PostgresCDCSource) processMessage(batch *model.RecordBatch, xld pglogre case *pglogrepl.BeginMessage: log.Debugf("BeginMessage => FinalLSN: %v, XID: %v", msg.FinalLSN, msg.Xid) log.Debugf("Locking PullRecords at BeginMessage, awaiting CommitMessage") - p.commitLock = true + if utils.GetEnvBool("PEERDB_BETA_EVENTHUB_PUSH_ASYNC", false) { + p.commitLock = false + } else { + p.commitLock = true + } case *pglogrepl.InsertMessage: return p.processInsertMessage(xld.WALStart, msg) case *pglogrepl.UpdateMessage: