Merge pull request #1650 from Shopify/seb-heartbeat-error

Return the response error in heartbeatLoop
IBM · Mar 23, 2020 · af1423a · af1423a
2 parents 18d3a27 + a74c07e
commit af1423a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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
 		}