Merge pull request #2193 from niamster/fix-heartbeat-on-rebalance

consumer-group: do not cancel sessions context during rebalance
IBM · Mar 30, 2022 · 9473433 · 9473433
2 parents 66f7198 + 82f0244
commit 9473433
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: