Revert "for eventhub disable commit lock (#546)" (#551)

This reverts commit 41dfd4f.
PeerDB-io · Oct 21, 2023 · eb4024d · eb4024d
1 parent 9a3e1ee
commit eb4024d
Showing 1 changed file with 1 addition and 5 deletions.
diff --git a/flow/connectors/postgres/cdc.go b/flow/connectors/postgres/cdc.go
@@ -317,11 +317,7 @@ 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")
-		if utils.GetEnvBool("PEERDB_BETA_EVENTHUB_PUSH_ASYNC", false) {
-			p.commitLock = false
-		} else {
-			p.commitLock = true
-		}
+		p.commitLock = true
 	case *pglogrepl.InsertMessage:
 		return p.processInsertMessage(xld.WALStart, msg)
 	case *pglogrepl.UpdateMessage: