diff --git a/server/jetstream_cluster.go b/server/jetstream_cluster.go index 8c707f86..6390a605 100644 --- a/server/jetstream_cluster.go +++ b/server/jetstream_cluster.go @@ -544,9 +544,11 @@ func (js *jetStream) setupMetaGroup() error { sysAcc := s.SystemAccount() storeDir := filepath.Join(js.config.StoreDir, sysAcc.Name, defaultStoreDirName, defaultMetaGroupName) - fs, err := newFileStore( + fs, err := newFileStoreWithCreated( FileStoreConfig{StoreDir: storeDir, BlockSize: defaultMetaFSBlkSize, AsyncFlush: false}, StreamConfig{Name: defaultMetaGroupName, Storage: FileStorage}, + time.Now().UTC(), + s.jsKeyGen(defaultMetaGroupName), ) if err != nil { s.Errorf("Error creating filestore: %v", err) @@ -1527,9 +1529,11 @@ func (js *jetStream) createRaftGroup(accName string, rg *raftGroup, storage Stor storeDir := filepath.Join(js.config.StoreDir, sysAcc.Name, defaultStoreDirName, rg.Name) var store StreamStore if storage == FileStorage { - fs, err := newFileStore( + fs, err := newFileStoreWithCreated( FileStoreConfig{StoreDir: storeDir, BlockSize: defaultMediumBlockSize, AsyncFlush: false, SyncInterval: 5 * time.Minute}, StreamConfig{Name: rg.Name, Storage: FileStorage}, + time.Now().UTC(), + s.jsKeyGen(rg.Name), ) if err != nil { s.Errorf("Error creating filestore WAL: %v", err)