From d946736f0cecd8b2f274285890a4abdc4373019a Mon Sep 17 00:00:00 2001 From: Zach Musgrave Date: Tue, 27 Feb 2024 15:38:52 -0800 Subject: [PATCH] Revert startReplication param change --- server/logrepl/replication.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/server/logrepl/replication.go b/server/logrepl/replication.go index 6a3dce617f..0f89997294 100755 --- a/server/logrepl/replication.go +++ b/server/logrepl/replication.go @@ -396,8 +396,8 @@ func (r *LogicalReplicator) beginReplication(slotName string) (*pgconn.PgConn, e } // LSN(0) is used to use the last confirmed LSN for this slot - log.Printf("Starting logical replication on slot %s from LSN %s", slotName, r.lsn) - err = pglogrepl.StartReplication(context.Background(), conn, slotName, r.lsn, pglogrepl.StartReplicationOptions{PluginArgs: pluginArguments}) + log.Printf("Starting logical replication on slot %s", slotName) + err = pglogrepl.StartReplication(context.Background(), conn, slotName, pglogrepl.LSN(0), pglogrepl.StartReplicationOptions{PluginArgs: pluginArguments}) if err != nil { return nil, err }