diff --git a/backend/config/autoload/mq_user.php b/backend/config/autoload/mq_user.php
index dfadeef..75ca456 100644
--- a/backend/config/autoload/mq_user.php
+++ b/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', ''),
     ],