From fb6cba0c453c61797578662b56c2254263a52f5e Mon Sep 17 00:00:00 2001 From: "Jibon L. Costa" Date: Sat, 7 Dec 2024 14:30:39 +0100 Subject: [PATCH] fix: missed to add `Replicas` --- pkg/services/nats/user_modify.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/pkg/services/nats/user_modify.go b/pkg/services/nats/user_modify.go index 94e6012a..bd929ce0 100644 --- a/pkg/services/nats/user_modify.go +++ b/pkg/services/nats/user_modify.go @@ -56,7 +56,8 @@ func (s *NatsService) AddUser(roomId, userId, name string, isAdmin, isPresenter // now we'll create different bucket for info kv, err = s.js.CreateOrUpdateKeyValue(s.ctx, jetstream.KeyValueConfig{ - Bucket: fmt.Sprintf(UserInfoBucket, roomId, userId), + Replicas: s.app.NatsInfo.NumReplicas, + Bucket: fmt.Sprintf(UserInfoBucket, roomId, userId), }) if err != nil { return err