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-08-19 15:41:30 +08:00
parent c2a46396ff
commit 5792ac3e22
1 changed files with 2 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Kafka/Kafka.php
+2 -4
View File
@@ -10,23 +10,21 @@ use RdKafka\ConsumerTopic;
use RdKafka\Exception; use RdKafka\Exception;
use RdKafka\KafkaConsumer; use RdKafka\KafkaConsumer;
use RdKafka\TopicConf; use RdKafka\TopicConf;
use Server\SInterface\CustomProcess;
use Kiri\Abstracts\Config; use Kiri\Abstracts\Config;
use Kiri\Exception\ConfigException; use Kiri\Exception\ConfigException;
use Kiri\Kiri; use Kiri\Kiri;
use Swoole\Coroutine\Channel; use Swoole\Coroutine\Channel;
use Swoole\Process; use Swoole\Process;
use Throwable; use Throwable;
use Server\Abstracts\CustomProcess;
/** /**
* Class Queue * Class Queue
* @package Queue * @package Queue
*/ */
class Kafka implements CustomProcess class Kafka extends CustomProcess
{ {
protected Channel $channel;
/** /**
* @param array $kafkaConfig * @param array $kafkaConfig