From a1a9a087c5d2bbc7dae9906e97f68c17c5250b1e Mon Sep 17 00:00:00 2001
From: hailin <hailin.zhao@gdzx.xyz>
Date: Sun, 21 Dec 2025 22:40:31 -0800
Subject: [PATCH] =?UTF-8?q?fix(admin-service):=20=E4=BF=AE=E5=A4=8D=20Kafk?=
 =?UTF-8?q?a=20topic=20=E8=AE=A2=E9=98=85=E4=B8=8D=E5=8C=B9=E9=85=8D?=
 =?UTF-8?q?=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

问题：admin-web 用户管理页面无数据
原因：admin-service 订阅的是 'identity.events'，
     但 identity-service 发送到的是具体的 topic 如 'identity.UserAccountCreated'

修复：将订阅的 topics 改为与 identity-service 的 IDENTITY_TOPICS 一致：
- identity.UserAccountCreated
- identity.UserAccountAutoCreated
- identity.PhoneBound
- identity.KYCSubmitted
- identity.KYCVerified
- identity.KYCRejected
- identity.UserAccountFrozen
- identity.UserAccountDeactivated

🤖 Generated with [Claude Code](https://claude.com/claude-code)

Co-Authored-By: Claude Sonnet 4.5 <noreply@anthropic.com>
---
 .../kafka/user-event-consumer.service.ts            | 13 +++++++++++--
 1 file changed, 11 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 9de7ccbc..b8059210 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
@@ -118,8 +118,17 @@ export class UserEventConsumerService implements OnModuleInit, OnModuleDestroy {
     this.consumerGroup = this.configService.get<string>('KAFKA_CONSUMER_GROUP', 'admin-service-user-sync');
     this.ackTopic = 'identity.events.ack';
 
-    // 订阅的主题
-    this.topics = ['identity.events'];
+    // 订阅的主题 (与 identity-service 的 IDENTITY_TOPICS 保持一致)
+    this.topics = [
+      'identity.UserAccountCreated',
+      'identity.UserAccountAutoCreated',
+      'identity.PhoneBound',
+      'identity.KYCSubmitted',
+      'identity.KYCVerified',
+      'identity.KYCRejected',
+      'identity.UserAccountFrozen',
+      'identity.UserAccountDeactivated',
+    ];
 
     this.kafka = new Kafka({
       clientId,