Skip to content

Commit

Permalink
Merge pull request #584 from ripienaar/priority_unpin_fix
Browse files Browse the repository at this point in the history
Fix unpinning
  • Loading branch information
ripienaar authored Nov 7, 2024
2 parents b844b4e + 2d7d269 commit 5975809
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion consumers.go
Original file line number Diff line number Diff line change
Expand Up @@ -984,7 +984,7 @@ func (c *Consumer) Unpin(group string) error {
return fmt.Errorf("group is required")
}

if c.cfg.PriorityPolicy == api.PriorityPinnedClient {
if c.cfg.PriorityPolicy != api.PriorityPinnedClient {
return fmt.Errorf("consumer is not configured for pinned clients")
}

Expand Down

0 comments on commit 5975809

Please sign in to comment.