as2252258/kiri-core
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 2 Wiki Activity

改名

Browse Source
This commit is contained in:
Mr·x
2021-03-24 19:41:21 +08:00
parent 5ecff9ca7c
commit 5c63a9a894
1 changed files with 1 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Kafka/Producer.php
+1 -4
View File
@@ -108,10 +108,7 @@ class Producer extends Component
} else if (!isset($consumers['groupId'])) { } else if (!isset($consumers['groupId'])) {
$consumers['groupId'] = $topic . ':' . Snowflake::localhost(); $consumers['groupId'] = $topic . ':' . Snowflake::localhost();
} }
$this->setGroupId($consumers['groupId'])->setTopic($topic)
var_dump(swoole_serialize($params));
$this->setGroupId($groupId)->setTopic($topic)
->setBrokers($consumers['brokers']) ->setBrokers($consumers['brokers'])
->delivery(swoole_serialize($params)); ->delivery(swoole_serialize($params));
} }