Преглед на файлове

Return the response error in heartbeatLoop

`err` is always `nil`, it is checked above already.
Sebastien Lavoie преди 5 години
родител
ревизия
a74c07e4d6
променени са 1 файла, в които са добавени 1 реда и са изтрити 1 реда
  1. 1 1
      consumer_group.go

+ 1 - 1
consumer_group.go

@@ -760,7 +760,7 @@ func (s *consumerGroupSession) heartbeatLoop() {
 		case ErrRebalanceInProgress, ErrUnknownMemberId, ErrIllegalGeneration:
 			return
 		default:
-			s.parent.handleError(err, "", -1)
+			s.parent.handleError(resp.Err, "", -1)
 			return
 		}