Revert "consumer-group: do not cancel sessions context during rebalance"

IBM · Mar 31, 2022 · 0c7e068 · 0c7e068
1 parent 9473433
commit 0c7e068
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: