push things through

PeerDB-io · Dec 18, 2023 · e905eea · e905eea
1 parent 9611710
commit e905eea
Showing 1 changed file with 0 additions and 1 deletion.
diff --git 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 {