From bb6b04e75ac83fe83357674e4c53d2576fa0b3c6 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Scott=20C=C3=B4t=C3=A9?= Date: Fri, 28 Mar 2025 13:42:24 -0400 Subject: [PATCH] Handle more than 4 result columns from IDENTIFY_SYSTEM --- pglogrepl.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/pglogrepl.go b/pglogrepl.go index 85b24b5..bb5b547 100644 --- a/pglogrepl.go +++ b/pglogrepl.go @@ -247,8 +247,8 @@ func ParseCreateReplicationSlot(mrr *pgconn.MultiResultReader) (CreateReplicatio } row := result.Rows[0] - if len(row) != 4 { - return crsr, fmt.Errorf("expected 4 result columns, got %d", len(row)) + if len(row) < 4 { + return crsr, fmt.Errorf("expected at least 4 result columns, got %d", len(row)) } crsr.SlotName = string(row[0])