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-16 15:46:07 +08:00
parent 30f098040c
commit 047dcad535
1 changed files with 3 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Kafka/Kafka.php
+3 -9
View File
@@ -11,15 +11,9 @@ use RdKafka\Exception;
use RdKafka\KafkaConsumer; use RdKafka\KafkaConsumer;
use RdKafka\TopicConf; use RdKafka\TopicConf;
use Snowflake\Exception\ComponentException; use Snowflake\Exception\ComponentException;
use Snowflake\Exception\ConfigException;
use Snowflake\Snowflake; use Snowflake\Snowflake;
use Swoole\Coroutine;
use Swoole\Coroutine\Channel; use Swoole\Coroutine\Channel;
use Swoole\Coroutine\WaitGroup;
use Swoole\IDEHelper\StubGenerators\Swoole;
use Swoole\Process; use Swoole\Process;
use Snowflake\Abstracts\Config as SConfig;
use Swoole\Timer;
use Throwable; use Throwable;
/** /**
@@ -73,7 +67,7 @@ class Kafka extends \Snowflake\Process\Process
/** /**
* @param ConsumerTopic $topic * @param ConsumerTopic $topic
* @param $interval * @param $interval
* @throws ComponentException * @throws \Exception
*/ */
private function resolve(ConsumerTopic $topic, $interval) private function resolve(ConsumerTopic $topic, $interval)
{ {
@@ -100,7 +94,7 @@ class Kafka extends \Snowflake\Process\Process
/** /**
* @param $topic * @param $topic
* @param $message * @param $message
* @throws ComponentException * @throws \Exception
*/ */
protected function handlerExecute($topic, $message) protected function handlerExecute($topic, $message)
{ {
@@ -127,7 +121,7 @@ class Kafka extends \Snowflake\Process\Process
/** /**
* @param $kafka * @param $kafka
* @return array * @return array
* @throws ComponentException * @throws \Exception
*/ */
private function kafkaConfig($kafka): array private function kafkaConfig($kafka): array
{ {