diff --git a/server/jetstream_cluster.go b/server/jetstream_cluster.go index 5972ba5bae..0c6e0fd7ee 100644 --- a/server/jetstream_cluster.go +++ b/server/jetstream_cluster.go @@ -528,6 +528,7 @@ func (js *jetStream) isStreamHealthy(acc *Account, sa *streamAssignment) bool { } } else if node != nil && node != mset.raftNode() { s.Warnf("Detected stream cluster node skew '%s > %s'", acc.GetName(), streamName) + node.Delete() mset.resetClusteredState(nil) }