From 6ab3f9281349c30be5674279230d36033f98ab2a Mon Sep 17 00:00:00 2001 From: hailin Date: Tue, 9 Dec 2025 03:31:26 -0800 Subject: [PATCH] fix(mpc-service): don't block HTTP server startup during Kafka rebalance --- .../services/event-consumer-starter.service.ts | 11 +++++------ 1 file changed, 5 insertions(+), 6 deletions(-) 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..2f6057e7 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 @@ -14,12 +14,11 @@ export class EventConsumerStarterService implements OnApplicationBootstrap { constructor(private readonly eventConsumer: EventConsumerService) {} - async onApplicationBootstrap() { - try { - await this.eventConsumer.startConsuming(); - this.logger.log('MPC event consumers started successfully'); - } catch (error) { + onApplicationBootstrap() { + // Don't await - let HTTP server start immediately while Kafka rebalances in background + this.eventConsumer.startConsuming().catch((error) => { this.logger.error('Failed to start MPC event consumers', error); - } + }); + this.logger.log('MPC event consumers starting in background'); } }