From 5d43787b3d03570466a0fe2210984ff00e75b3f0 Mon Sep 17 00:00:00 2001 From: Kevin Biju Date: Thu, 12 Dec 2024 20:23:09 +0530 Subject: [PATCH] [cdc] treat all pkms as reply_requested --- flow/connectors/postgres/cdc.go | 7 ++----- 1 file changed, 2 insertions(+), 5 deletions(-) diff --git a/flow/connectors/postgres/cdc.go b/flow/connectors/postgres/cdc.go index 65924c13f..c8a9fe769 100644 --- a/flow/connectors/postgres/cdc.go +++ b/flow/connectors/postgres/cdc.go @@ -495,15 +495,12 @@ func PullCdcRecords[Items model.Items]( return fmt.Errorf("ParsePrimaryKeepaliveMessage failed: %w", err) } - logger.Debug("Primary Keepalive Message", slog.Any("data", pkm)) + logger.Info("Primary Keepalive Message", slog.Any("data", pkm)) if pkm.ServerWALEnd > clientXLogPos { clientXLogPos = pkm.ServerWALEnd } - - if pkm.ReplyRequested { - pkmRequiresResponse = true - } + pkmRequiresResponse = true case pglogrepl.XLogDataByteID: xld, err := pglogrepl.ParseXLogData(msg.Data[1:])