diff --git a/internal/persistence/database.go b/internal/persistence/database.go
index bdd975f..2b21b8d 100644
--- a/internal/persistence/database.go
+++ b/internal/persistence/database.go
@@ -121,6 +121,12 @@ func NewDBStore(clusterID uint, fleetName string, log *zap.Logger, options ...DB
 		}
 	}
 
+	result.db.Exec("update missingMessages set fleet = 'status.prod'")
+
+	result.db.Exec("update storeNodeUnavailable set fleet = 'status.prod'")
+
+	result.db.Exec("update syncTopicStatus set fleet = 'status.prod'")
+
 	return result, nil
 }