Merge pull request #2201 from niamster/revert-2193-fix-heartbeat-on-r…

…ebalance Revert "consumer-group: do not cancel sessions context during rebalance"
IBM · Apr 11, 2022 · c9cefb2 · c9cefb2
2 parents 9473433 + 0c7e068
commit c9cefb2
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/consumer_group.go b/consumer_group.go
@@ -869,6 +869,7 @@ func (s *consumerGroupSession) heartbeatLoop() {
 			retries = s.parent.config.Metadata.Retry.Max
 		case ErrRebalanceInProgress:
 			retries = s.parent.config.Metadata.Retry.Max
+			s.cancel()
 		case ErrUnknownMemberId, ErrIllegalGeneration:
 			return
 		default: