异常

[mobility2015]

public function failSyncGroup($errorCode) { $error = sprintf('Sync group fail, need rejoin, errorCode %d, memberId: %s', $errorCode, $memberId); $this->error($error); $this->stateConvert($errorCode); }

这段代码中有异常，需要增加 $assign = \Kafka\Consumer\Assignment::getInstance(); $memberId = $assign->getMemberId();