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-05 16:27:53 +08:00
parent e3f1eeda55
commit b2e3f7442a
1 changed files with 1 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Kafka/Kafka.php
+1 -4
View File
@@ -10,12 +10,9 @@ use RdKafka\ConsumerTopic;
use RdKafka\Exception; use RdKafka\Exception;
use RdKafka\KafkaConsumer; use RdKafka\KafkaConsumer;
use RdKafka\TopicConf; use RdKafka\TopicConf;
use ReflectionException;
use Server\ServerManager;
use Server\SInterface\CustomProcess; use Server\SInterface\CustomProcess;
use Snowflake\Abstracts\Config; use Snowflake\Abstracts\Config;
use Snowflake\Exception\ConfigException; use Snowflake\Exception\ConfigException;
use Snowflake\Exception\NotFindClassException;
use Snowflake\Snowflake; use Snowflake\Snowflake;
use Swoole\Coroutine\Channel; use Swoole\Coroutine\Channel;
use Swoole\Process; use Swoole\Process;
@@ -127,10 +124,10 @@ class Kafka implements CustomProcess
$setting = $server->setting['worker_num']; $setting = $server->setting['worker_num'];
var_dump($topic, $message);
$container = Snowflake::app()->get('kafka-container'); $container = Snowflake::app()->get('kafka-container');
$handler = $container->getConsumer($topic); $handler = $container->getConsumer($topic);
var_dump($topic, $message, $handler);
if (!empty($handler)) { if (!empty($handler)) {
/** @var ConsumerInterface $data */ /** @var ConsumerInterface $data */
$data = new $handler(); $data = new $handler();