diff --git a/flow/connectors/postgres/cdc.go b/flow/connectors/postgres/cdc.go
index 97ac511304..779f3f19b5 100644
--- a/flow/connectors/postgres/cdc.go
+++ b/flow/connectors/postgres/cdc.go
@@ -241,7 +241,6 @@ func (p *PostgresCDCSource) consumeStream(
 	pkmRequiresResponse := false
 	waitingForCommit := false
 	maxBatchSize := req.MaxBatchSize
-	maxBatchSize = 1000
 
 	for {
 		if pkmRequiresResponse {