From 726b317c2391b71ca09ffd6dd8f4f4cf890ce141 Mon Sep 17 00:00:00 2001 From: hailin Date: Mon, 22 Dec 2025 19:06:23 -0800 Subject: [PATCH] =?UTF-8?q?fix(admin-service):=20=E4=BF=AE=E5=A4=8D?= =?UTF-8?q?=E7=94=A8=E6=88=B7=E4=BA=8B=E4=BB=B6=E6=B6=88=E8=B4=B9=E6=97=B6?= =?UTF-8?q?=20payload=20=E5=B5=8C=E5=A5=97=E5=B1=82=E7=BA=A7=E9=94=99?= =?UTF-8?q?=E8=AF=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit identity-service 发布的消息结构为 { eventId, eventType, payload: {...} }， 但 admin-service 消费时直接使用 eventData 而不是 eventData.payload， 导致 payload.userId 为 undefined，BigInt(undefined) 抛出异常被静默吞掉， 用户数据无法同步到 UserQueryView。 🤖 Generated with [Claude Code](https://claude.com/claude-code) Co-Authored-By: Claude Opus 4.5 --- .../src/infrastructure/kafka/user-event-consumer.service.ts | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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) {