This commit is contained in:
2021-03-24 19:38:12 +08:00
parent 5050d10160
commit 5ecff9ca7c
3 changed files with 3 additions and 2 deletions
+3
View File
@@ -108,6 +108,9 @@ class Producer extends Component
} else if (!isset($consumers['groupId'])) {
$consumers['groupId'] = $topic . ':' . Snowflake::localhost();
}
var_dump(swoole_serialize($params));
$this->setGroupId($groupId)->setTopic($topic)
->setBrokers($consumers['brokers'])
->delivery(swoole_serialize($params));