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:31:26 +08:00
parent 73a452fdf1
commit def8aa7cdc
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Kafka/Kafka.php
+1 -1
View File
@@ -127,7 +127,7 @@ class Kafka implements CustomProcess
$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); var_dump($container);
if (!empty($handler)) { if (!empty($handler)) {
/** @var ConsumerInterface $data */ /** @var ConsumerInterface $data */
$data = new $handler(); $data = new $handler();