diff --git a/backend/services/mining-admin-service/src/infrastructure/kafka/cdc-consumer.service.ts b/backend/services/mining-admin-service/src/infrastructure/kafka/cdc-consumer.service.ts
index 7611818f..b4d792d4 100644
--- a/backend/services/mining-admin-service/src/infrastructure/kafka/cdc-consumer.service.ts
+++ b/backend/services/mining-admin-service/src/infrastructure/kafka/cdc-consumer.service.ts
@@ -317,9 +317,17 @@ export class CdcConsumerService implements OnModuleInit, OnModuleDestroy {
    * 将 Debezium outbox 的下划线格式转换为驼峰格式
    */
   private normalizeServiceEvent(data: any): Omit<ServiceEvent, 'sequenceNum' | 'sourceTopic'> {
-    // 如果已经是驼峰格式，直接返回
+    // 如果已经是驼峰格式（mining-wallet-service 直接发布的事件）
+    // 注意：mining-wallet-service 使用 eventId 而不是 id
     if (data.eventType && data.aggregateType) {
-      return data;
+      return {
+        id: data.id ?? data.eventId,
+        eventType: data.eventType,
+        aggregateType: data.aggregateType,
+        aggregateId: data.aggregateId,
+        payload: data.payload,
+        createdAt: data.createdAt,
+      };
     }
 
     // Debezium outbox 格式转换