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 962b343a..e2208e01 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 @@ -66,8 +66,10 @@ export class EventConsumerService implements OnModuleInit, OnModuleDestroy { this.consumer = this.kafka.consumer({ groupId, - sessionTimeout: 30000, - heartbeatInterval: 3000, + sessionTimeout: 300000, // 5 minutes - MPC keygen can take a while + heartbeatInterval: 10000, // 10 seconds + maxWaitTimeInMs: 5000, + rebalanceTimeout: 300000, // 5 minutes }); try {