Merge pull request #553 from ripienaar/consumer_leader_fix

Fix conditional for consumer leader find
nats-io · Aug 5, 2024 · 6b02e19 · 6b02e19
2 parents bd1b67e + aa20bea
commit 6b02e19
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/consumer_query.go b/consumer_query.go
@@ -221,7 +221,7 @@ func (q *consumerQuery) cbMatcher(consumers []*Consumer, onlyIf bool, cb func(*C
 }
 
 func (q *consumerQuery) matchLeaderServer(consumers []*Consumer) ([]*Consumer, error) {
-	return q.cbMatcher(consumers, q.replicas > 0, func(consumer *Consumer) bool {
+	return q.cbMatcher(consumers, q.leader != "", func(consumer *Consumer) bool {
 		nfo, _ := consumer.LatestState()
 		if nfo.Cluster == nil {
 			return false