diff --git a/backend/services/admin-service/src/infrastructure/kafka/user-event-consumer.service.ts b/backend/services/admin-service/src/infrastructure/kafka/user-event-consumer.service.ts index b8059210..5249d34c 100644 --- a/backend/services/admin-service/src/infrastructure/kafka/user-event-consumer.service.ts +++ b/backend/services/admin-service/src/infrastructure/kafka/user-event-consumer.service.ts @@ -210,8 +210,8 @@ export class UserEventConsumerService implements OnModuleInit, OnModuleDestroy { return; } - // 处理事件 - await this.processEvent(eventType, eventData); + // 处理事件 (eventData.payload 包含实际的业务数据) + await this.processEvent(eventType, eventData.payload); // 记录已处理事件 if (eventId) {