diff --git a/backend/services/mpc-service/src/infrastructure/messaging/kafka/event-consumer.service.ts b/backend/services/mpc-service/src/infrastructure/messaging/kafka/event-consumer.service.ts index 6cb66004..2df4dc67 100644 --- a/backend/services/mpc-service/src/infrastructure/messaging/kafka/event-consumer.service.ts +++ b/backend/services/mpc-service/src/infrastructure/messaging/kafka/event-consumer.service.ts @@ -67,10 +67,10 @@ export class EventConsumerService implements OnModuleInit, OnModuleDestroy { this.consumer = this.kafka.consumer({ groupId, - sessionTimeout: 300000, // 5 minutes - MPC keygen can take a while - heartbeatInterval: 10000, // 10 seconds + sessionTimeout: 30000, // 30 seconds - enough for normal operations + heartbeatInterval: 3000, // 3 seconds maxWaitTimeInMs: 5000, - rebalanceTimeout: 300000, // 5 minutes + rebalanceTimeout: 60000, // 60 seconds - for MPC operations }); try {