Merge pull request #2850 from gravitl/release-v0.23.0

Release v0.23.0
gravitl · Mar 5, 2024 · d390f44 · d390f44
2 parents 37e877c + e7eb40a
commit d390f44
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/migrate/migrate.go b/migrate/migrate.go
@@ -307,7 +307,7 @@ func MigrateEmqx() {
 	slog.Info("proceeding to kicking out clients from emqx")
 	err = mq.KickOutClients()
 	if err != nil {
-		logger.Log(0, "failed to migrate emqx: ", "kickout-error", err.Error())
+		logger.Log(2, "failed to migrate emqx: ", "kickout-error", err.Error())
 	}
 
 }
diff --git a/mq/mq.go b/mq/mq.go
@@ -60,6 +60,7 @@ func SetupMQTT() {
 				log.Fatal(err)
 			}
 		} else {
+			emqx.DeleteEmqxUser(servercfg.GetMqUserName())
 			if err := emqx.CreateEmqxUserforServer(); err != nil {
 				log.Fatal(err)
 			}