consumer-group: do not cancel sessions context during rebalance

IBM · Mar 23, 2022 · 82f0244 · 82f0244
1 parent bad67e5
commit 82f0244
Showing 1 changed file with 0 additions and 1 deletion.
diff --git a/consumer_group.go b/consumer_group.go
@@ -869,7 +869,6 @@ 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: