From e905eea9840e8a4d3a5a8d338f247b849a3bdad4 Mon Sep 17 00:00:00 2001
From: Kaushik Iska <iska.kaushik@gmail.com>
Date: Sun, 17 Dec 2023 19:22:26 -0500
Subject: [PATCH] push things through

---
 flow/connectors/postgres/cdc.go | 1 -
 1 file changed, 1 deletion(-)

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 {