This commit is contained in:
2021-04-01 10:50:13 +08:00
parent 2a1f984be8
commit e56ab4a364
-1
View File
@@ -105,7 +105,6 @@ 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));