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:21:02 +08:00
parent c29a1a7f19
commit 1502435942
1 changed files with 11 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Kafka/Producer.php
+11 -7
View File
@@ -98,14 +98,18 @@ class Producer extends Component
*/ */
public function dispatch(string $topic, array $params = [], string $groupId = null) public function dispatch(string $topic, array $params = [], string $groupId = null)
{ {
if ($groupId === null || empty($groupId)) { $consumers = Config::get('kafka.consumers.' . $topic);
$consumers = Config::get('kafka.consumers.' . $topic); if (empty($consumers) || !is_array($consumers)) {
if (empty($consumers)) { return;
$consumers = ['groupId' => $topic . ':' . Snowflake::localhost()];
}
$groupId = $consumers['groupId'];
} }
$this->setGroupId($groupId)->setTopic($topic)->delivery(swoole_serialize($params));
if (!empty($groupId)) {
$consumers['groupId'] = $groupId;
} else if (!isset($consumers['groupId'])) {
$consumers['groupId'] = $topic . ':' . Snowflake::localhost();
}
$this->setGroupId($groupId)->setTopic($topic)
->delivery(swoole_serialize($params));
} }