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

lavoiesl · web-flow · commit af1423ad225e · 2020-03-23T14:08:25.000-04:00
Return the response error in heartbeatLoop
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
 		}
 

Original file line number	Diff line number	Diff line change
`@@ -760,7 +760,7 @@ func (s *consumerGroupSession) heartbeatLoop() {`
`760`	`760`	`case ErrRebalanceInProgress, ErrUnknownMemberId, ErrIllegalGeneration:`
`761`	`761`	`return`
`762`	`762`	`default:`
`763`		`- s.parent.handleError(err, "", -1)`
	`763`	`+ s.parent.handleError(resp.Err, "", -1)`
`764`	`764`	`return`
`765`	`765`	`}`
`766`	`766`