diff --git a/backend/services/mpc-service/src/application/services/event-consumer-starter.service.ts b/backend/services/mpc-service/src/application/services/event-consumer-starter.service.ts index e7d4f092..bf2b6bf6 100644 --- a/backend/services/mpc-service/src/application/services/event-consumer-starter.service.ts +++ b/backend/services/mpc-service/src/application/services/event-consumer-starter.service.ts @@ -16,7 +16,11 @@ export class EventConsumerStarterService implements OnApplicationBootstrap { async onApplicationBootstrap() { try { - await this.eventConsumer.startConsuming(); + // Don't await - consumer.run() never resolves (it runs continuously) + // Just fire and forget, let it run in the background + this.eventConsumer.startConsuming().catch((error) => { + this.logger.error('Kafka consumer error', error); + }); this.logger.log('MPC event consumers started successfully'); } catch (error) { this.logger.error('Failed to start MPC event consumers', error);