more logging LSN better

PeerDB-io · Dec 17, 2024 · d528fc9 · d528fc9
1 parent 3292a4e
commit d528fc9
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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))
 		}