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('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,