改名
This commit is contained in:
@@ -127,6 +127,7 @@ 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);
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user