diff --git a/backend/services/mining-wallet-service/src/application/application.module.ts b/backend/services/mining-wallet-service/src/application/application.module.ts
index 1b74fcd0..dd70a6c4 100644
--- a/backend/services/mining-wallet-service/src/application/application.module.ts
+++ b/backend/services/mining-wallet-service/src/application/application.module.ts
@@ -12,6 +12,10 @@ import { ContributionWalletService } from './services/contribution-wallet.servic
 import { OutboxScheduler } from './schedulers/outbox.scheduler';
 import { ContributionExpiryScheduler } from './schedulers/contribution-expiry.scheduler';
 
+// Consumers (从 InfrastructureModule 移过来，因为依赖应用服务)
+import { ContributionDistributionConsumer } from '../infrastructure/kafka/consumers/contribution-distribution.consumer';
+import { UserRegisteredConsumer } from '../infrastructure/kafka/consumers/user-registered.consumer';
+
 @Module({
   imports: [ScheduleModule.forRoot()],
   providers: [
@@ -24,6 +28,9 @@ import { ContributionExpiryScheduler } from './schedulers/contribution-expiry.sc
     // Schedulers
     OutboxScheduler,
     ContributionExpiryScheduler,
+    // Consumers
+    ContributionDistributionConsumer,
+    UserRegisteredConsumer,
   ],
   exports: [
     SystemAccountService,
diff --git a/backend/services/mining-wallet-service/src/infrastructure/infrastructure.module.ts b/backend/services/mining-wallet-service/src/infrastructure/infrastructure.module.ts
index f813a745..b2a97d67 100644
--- a/backend/services/mining-wallet-service/src/infrastructure/infrastructure.module.ts
+++ b/backend/services/mining-wallet-service/src/infrastructure/infrastructure.module.ts
@@ -12,8 +12,7 @@ import { ProcessedEventRepository } from './persistence/repositories/processed-e
 import { RedisService } from './redis/redis.service';
 import { KafkaProducerService } from './kafka/kafka-producer.service';
 import { KavaBlockchainService } from './blockchain/kava-blockchain.service';
-import { ContributionDistributionConsumer } from './kafka/consumers/contribution-distribution.consumer';
-import { UserRegisteredConsumer } from './kafka/consumers/user-registered.consumer';
+// 注意: Consumers 移到 ApplicationModule 中，因为它们依赖应用服务
 
 @Global()
 @Module({
@@ -56,9 +55,7 @@ import { UserRegisteredConsumer } from './kafka/consumers/user-registered.consum
     // Services
     KafkaProducerService,
     KavaBlockchainService,
-    // Consumers
-    ContributionDistributionConsumer,
-    UserRegisteredConsumer,
+    // Consumers 已移到 ApplicationModule
     {
       provide: 'REDIS_OPTIONS',
       useFactory: (configService: ConfigService) => ({