diff --git a/backend/services/admin-service/src/app.module.ts b/backend/services/admin-service/src/app.module.ts index 9b9f82c8..cb7d227e 100644 --- a/backend/services/admin-service/src/app.module.ts +++ b/backend/services/admin-service/src/app.module.ts @@ -34,6 +34,12 @@ import { USER_QUERY_REPOSITORY } from './domain/repositories/user-query.reposito import { UserController } from './api/controllers/user.controller'; import { UserDetailController } from './api/controllers/user-detail.controller'; import { UserEventConsumerService } from './infrastructure/kafka/user-event-consumer.service'; +// CDC Consumer imports +import { CdcConsumerService } from './infrastructure/kafka/cdc-consumer.service'; +import { ReferralCdcConsumerService } from './infrastructure/kafka/referral-cdc-consumer.service'; +import { WalletCdcConsumerService } from './infrastructure/kafka/wallet-cdc-consumer.service'; +import { PlantingCdcConsumerService } from './infrastructure/kafka/planting-cdc-consumer.service'; +import { AuthorizationCdcConsumerService } from './infrastructure/kafka/authorization-cdc-consumer.service'; // User Detail Query imports import { UserDetailQueryRepositoryImpl } from './infrastructure/persistence/repositories/user-detail-query.repository.impl'; import { USER_DETAIL_QUERY_REPOSITORY } from './domain/repositories/user-detail-query.repository'; @@ -141,6 +147,12 @@ import { MaintenanceInterceptor } from './api/interceptors/maintenance.intercept useClass: UserDetailQueryRepositoryImpl, }, UserEventConsumerService, + // CDC Consumers (Debezium) + CdcConsumerService, + ReferralCdcConsumerService, + WalletCdcConsumerService, + PlantingCdcConsumerService, + AuthorizationCdcConsumerService, // System Config { provide: SYSTEM_CONFIG_REPOSITORY,