diff --git a/server/metadata.go b/server/metadata.go index 0a1557fe..38ff984a 100644 --- a/server/metadata.go +++ b/server/metadata.go @@ -835,7 +835,7 @@ func (m *metadataAPI) CloseAndDeleteStream(stream *stream) error { return errors.Wrap(err, "failed to delete stream") } - // Remove the (now empty) stream data directory + // Remove the stream data directory streamDataDir := filepath.Join(m.Server.config.DataDir, "streams", stream.GetName()) err = os.RemoveAll(streamDataDir) if err != nil {