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

Fix for #2352

Browse Source 
Signed-off-by: Derek Collison <derek@nats.io>
This commit is contained in:
Derek Collison
2021-07-08 06:13:36 -07:00
parent c68ffe5ad5
commit 894f26d149
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
server/jetstream_api.go
View File

@@ -3377,6 +3377,7 @@ func (s *Server) jsConsumerInfoRequest(sub *subscription, c *client, subject, re
if ca != nil && ca.pending {
ca = nil
}
ourID := cc.meta.ID()
js.mu.RUnlock()
if isLeader && ca == nil {
@@ -3420,7 +3421,7 @@ func (s *Server) jsConsumerInfoRequest(sub *subscription, c *client, subject, re
// Delaying an error response gives the leader a chance to respond before us
s.sendDelayedAPIErrResponse(ci, acc, subject, reply, string(msg), s.jsonResponse(&resp), ca.Group)
} else if ca != nil {
if rg := ca.Group; rg != nil && rg.node != nil && rg.isMember(cc.meta.ID()) {
if rg := ca.Group; rg != nil && rg.node != nil && rg.isMember(ourID) {
// Check here if we are a member and this is just a new consumer that does not have a leader yet.
if rg.node.GroupLeader() == _EMPTY_ && !rg.node.HadPreviousLeader() {
resp.Error = ApiErrors[JSConsumerNotFoundErr]