kafka-php
kafka-php copied to clipboard
异常
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();