diff --git a/apps/websocket-server/internal/domain/logs/main.go b/apps/websocket-server/internal/domain/logs/main.go
index af5c6e4ae..fdbff3b8e 100644
--- a/apps/websocket-server/internal/domain/logs/main.go
+++ b/apps/websocket-server/internal/domain/logs/main.go
@@ -23,7 +23,7 @@ type MsgData struct {
 	Cluster       string  `json:"cluster"`
 	TrackingId    string  `json:"trackingId"`
 	Since         *string `json:"since,omitempty"`
-	RecordVersion int     `json:"recordVersion"`
+	RecordVersion *int    `json:"recordVersion"`
 }
 
 type Message struct {
@@ -101,5 +101,10 @@ func ParseSince(since *string) (*time.Time, error) {
 }
 
 func LogSubsId(md MsgData, logStreamName string) string {
+
+	if md.RecordVersion == nil {
+		return fmt.Sprintf("%s.%s.%s.%s.>", logStreamName, md.Account, md.Cluster, md.TrackingId)
+	}
+
 	return fmt.Sprintf("%s.%s.%s.%s.%d.>", logStreamName, md.Account, md.Cluster, md.TrackingId, md.RecordVersion)
 }