改名
This commit is contained in:
@@ -105,6 +105,7 @@ class Producer extends Component
|
||||
} else if (!isset($consumers['groupId'])) {
|
||||
$consumers['groupId'] = $topic . ':' . Snowflake::localhost();
|
||||
}
|
||||
var_dump($consumers['groupId'], $consumers['brokers'], $topic);
|
||||
$this->setGroupId($consumers['groupId'])->setTopic($topic)
|
||||
->setBrokers($consumers['brokers'])
|
||||
->delivery(swoole_serialize($params));
|
||||
|
||||
Reference in New Issue
Block a user