From d528fc9232f1a1691df82984b600679eeaed2649 Mon Sep 17 00:00:00 2001 From: Kevin Biju Date: Tue, 17 Dec 2024 15:07:51 +0530 Subject: [PATCH] more logging LSN better --- flow/connectors/postgres/cdc.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flow/connectors/postgres/cdc.go b/flow/connectors/postgres/cdc.go index 3748ef2c28..5158a960c8 100644 --- a/flow/connectors/postgres/cdc.go +++ b/flow/connectors/postgres/cdc.go @@ -702,7 +702,7 @@ func processMessage[Items model.Items]( logger.Info("LogicalDecodingMessage", slog.Bool("Transactional", msg.Transactional), slog.String("Prefix", msg.Prefix), - slog.Int64("LSN", int64(msg.LSN))) + slog.String("LSN", pglogrepl.LSN(msg.LSN).String())) if !msg.Transactional { batch.UpdateLatestCheckpoint(int64(msg.LSN)) }