for eventhub disable commit lock (#546)

PeerDB-io · Oct 20, 2023 · 41dfd4f · 41dfd4f
1 parent 8daacce
commit 41dfd4f
Showing 1 changed file with 5 additions and 1 deletion.
diff --git 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: