From a74c07e4d6980c01dd56e92914c52c14af7c548e Mon Sep 17 00:00:00 2001 From: Sebastien Lavoie Date: Mon, 23 Mar 2020 13:35:52 -0400 Subject: [PATCH] Return the response error in heartbeatLoop `err` is always `nil`, it is checked above already. --- consumer_group.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/consumer_group.go b/consumer_group.go index 0bc32b976..056b9e387 100644 --- a/consumer_group.go +++ b/consumer_group.go @@ -760,7 +760,7 @@ func (s *consumerGroupSession) heartbeatLoop() { case ErrRebalanceInProgress, ErrUnknownMemberId, ErrIllegalGeneration: return default: - s.parent.handleError(err, "", -1) + s.parent.handleError(resp.Err, "", -1) return }