Skip to content

Commit

Permalink
fixed handle cleanup error
Browse files Browse the repository at this point in the history
when cleanup return an error , why handle ‘err’ ( seem always nil ) ?
  • Loading branch information
forsaken628 authored Mar 29, 2019
1 parent a929fb1 commit b4d38af
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion consumer_group.go
Original file line number Diff line number Diff line change
Expand Up @@ -614,7 +614,7 @@ func (s *consumerGroupSession) release(withCleanup bool) (err error) {
s.releaseOnce.Do(func() {
if withCleanup {
if e := s.handler.Cleanup(s); e != nil {
s.parent.handleError(err, "", -1)
s.parent.handleError(e, "", -1)
err = e
}
}
Expand Down

0 comments on commit b4d38af

Please sign in to comment.