From 41fd15de649be8f3c813039e778d47b13809e0e7 Mon Sep 17 00:00:00 2001
From: Kaushik Iska <iska.kaushik@gmail.com>
Date: Tue, 21 Nov 2023 14:18:52 -0500
Subject: [PATCH] reply to pkms

---
 flow/connectors/postgres/cdc.go | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/flow/connectors/postgres/cdc.go b/flow/connectors/postgres/cdc.go
index d74a4a1503..81447766a2 100644
--- a/flow/connectors/postgres/cdc.go
+++ b/flow/connectors/postgres/cdc.go
@@ -324,9 +324,9 @@ func (p *PostgresCDCSource) consumeStream(
 				clientXLogPos = pkm.ServerWALEnd
 			}
 
-			if pkm.ReplyRequested {
-				pkmRequiresResponse = true
-			}
+			// always reply to keepalive messages
+			// instead of `pkm.ReplyRequested`
+			pkmRequiresResponse = true
 
 		case pglogrepl.XLogDataByteID:
 			xld, err := pglogrepl.ParseXLogData(msg.Data[1:])