From b4d38af3f38a1d79a90748c21718f2199971dc84 Mon Sep 17 00:00:00 2001
From: coldWater <254244460@qq.com>
Date: Fri, 29 Mar 2019 19:22:35 +0800
Subject: [PATCH] fixed handle cleanup error
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

when cleanup return an error , why handle ‘err’ ( seem always nil ) ？
---
 consumer_group.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/consumer_group.go b/consumer_group.go
index 7f9804dce..56f96ea13 100644
--- 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
 			}
 		}