update

backend/config/autoload/mq_user.php

@@ -3,6 +3,7 @@
 declare(strict_types=1);
 
 use Hyperf\DbConnection\Db;
+use function Hyperf\Support\env;
 
 /**
  * RabbitMQ 用户配置
@@ -18,7 +19,7 @@ use Hyperf\DbConnection\Db;
 return [
     // 消费者用户
     'consumer' => [
-        'user' => 'user_dataflow_consumer',
+        'user' => 'user_datahub_consumer',
         'password' => env('MQ_PASSWORD_CONSUMER', ''),
     ],