Merge pull request #1332 from forsaken628/patch-1

bai · web-flow · commit 6e69750ac452 · 2019-04-02T08:26:15.000+03:00
fixed handle cleanup error
diff --git a/consumer_group.go b/consumer_group.go
@@ -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
 			}
 		}

Original file line number	Diff line number	Diff line change
`@@ -614,7 +614,7 @@ func (s *consumerGroupSession) release(withCleanup bool) (err error) {`
`614`	`614`	`s.releaseOnce.Do(func() {`
`615`	`615`	`if withCleanup {`
`616`	`616`	`if e := s.handler.Cleanup(s); e != nil {`
`617`		`- s.parent.handleError(err, "", -1)`
	`617`	`+ s.parent.handleError(e, "", -1)`
`618`	`618`	`err = e`
`619`	`619`	`}`
`620`	`620`	`}`