diff --git a/consumer_group.go b/consumer_group.go
index 37576ad4d..18f587880 100644
--- 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: