Enhanced logging of restarting from last confirmed flush which now ma…

…y provide information about the alternative position in offset
noctarius · Jul 6, 2023 · 8cae860 · 8cae860
1 parent 47a5403
commit 8cae860
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/internal/replication/context/replicationconnection.go b/internal/replication/context/replicationconnection.go
@@ -237,7 +237,11 @@ func (rc *ReplicationConnection) locateRestartLSN(readReplicationSlot readReplic
 	}
 
 	if restartLSN == confirmedFlushLSN && !rc.replicationSlotCreated {
-		rc.logger.Infof("Restarting replication at last confirmed flush LSN: %s", restartLSN)
+		addMsg := ""
+		if offset != nil {
+			addMsg = fmt.Sprintf(" (lower offset LSN: %s)", offset.LSN.String())
+		}
+		rc.logger.Infof("Restarting replication at last confirmed flush LSN: %s%s", restartLSN, addMsg)
 	} else if offset != nil && restartLSN == offset.LSN {
 		rc.logger.Infof("Restarting replication at last LSN in offset storage: %s", restartLSN)
 	} else {