diff --git a/server/jetstream_super_cluster_test.go b/server/jetstream_super_cluster_test.go
index 4516532e..3c06d1c6 100644
--- a/server/jetstream_super_cluster_test.go
+++ b/server/jetstream_super_cluster_test.go
@@ -1660,6 +1660,7 @@ func TestJetStreamSuperClusterConsumerDeliverNewBug(t *testing.T) {
 		removeDir(t, sd)
 		s = c.restartServer(s)
 		c.waitOnServerHealthz(s)
+		c.waitOnConsumerLeader("$G", "T", "d")
 	}
 
 	c.waitOnConsumerLeader("$G", "T", "d")