gogrlx/nats-server
1
0
Fork 0
mirror of https://github.com/gogrlx/nats-server.git synced 2026-04-02 03:38:42 -07:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #3470 from goku321/random-consumer-peer

Browse Source 
Fix peer randomisation when creating consumers groups for replica=1
This commit is contained in:
Derek Collison
2022-09-14 07:53:26 -07:00
committed by GitHub
parent a41af2bdcb e9ce118c56
commit d4f313027c
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
server/jetstream_cluster.go
View File

@@ -5950,8 +5950,9 @@ func (cc *jetStreamCluster) createGroupForConsumer(cfg *ConsumerConfig, sa *stre
return nil
}
if cfg.Replicas > 0 && cfg.Replicas != len(peers) {
peers = peers[:cfg.Replicas]
// First shuffle the peers and then select to account for replica = 1.
rand.Shuffle(len(peers), func(i, j int) { peers[i], peers[j] = peers[j], peers[i] })
peers = peers[:cfg.Replicas]
}
storage := sa.Config.Storage
if cfg.MemoryStorage {