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:23:09 +08:00
parent 1502435942
commit 6787d7c2ae
1 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Kafka/Producer.php
+5 -4
View File
@@ -92,9 +92,7 @@ class Producer extends Component
* @param string $topic * @param string $topic
* @param array $params * @param array $params
* @param string|null $groupId * @param string|null $groupId
* @throws NotFindClassException * @throws Exception
* @throws ReflectionException
* @throws ConfigException
*/ */
public function dispatch(string $topic, array $params = [], string $groupId = null) public function dispatch(string $topic, array $params = [], string $groupId = null)
{ {
@@ -102,13 +100,16 @@ class Producer extends Component
if (empty($consumers) || !is_array($consumers)) { if (empty($consumers) || !is_array($consumers)) {
return; return;
} }
if (!isset($consumers['brokers'])) {
throw new Exception('You need set brokers config.');
}
if (!empty($groupId)) { if (!empty($groupId)) {
$consumers['groupId'] = $groupId; $consumers['groupId'] = $groupId;
} else if (!isset($consumers['groupId'])) { } else if (!isset($consumers['groupId'])) {
$consumers['groupId'] = $topic . ':' . Snowflake::localhost(); $consumers['groupId'] = $topic . ':' . Snowflake::localhost();
} }
$this->setGroupId($groupId)->setTopic($topic) $this->setGroupId($groupId)->setTopic($topic)
->setBrokers($consumers['brokers'])
->delivery(swoole_serialize($params)); ->delivery(swoole_serialize($params));
} }