Adding logging for debugging

dolthub · Feb 27, 2024 · 0e4eb69 · 0e4eb69
1 parent 19b91f8
commit 0e4eb69
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/server/logrepl/replication.go b/server/logrepl/replication.go
@@ -390,7 +390,8 @@ func (r *LogicalReplicator) beginReplication(slotName string) (*pgconn.PgConn, e
 	}
 
 	// LSN(0) is used to use the last confirmed LSN for this slot
-	err = pglogrepl.StartReplication(context.Background(), conn, slotName, pglogrepl.LSN(0), pglogrepl.StartReplicationOptions{PluginArgs: pluginArguments})
+	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})
 	if err != nil {
 		return nil, err
 	}