From 1eca8b3af8047aeeeaab34ba005cf1bdbd6aef3b Mon Sep 17 00:00:00 2001 From: hailin Date: Tue, 9 Dec 2025 03:24:00 -0800 Subject: [PATCH] fix(mpc-service): reduce Kafka session timeout from 5min to 30s --- .../messaging/kafka/event-consumer.service.ts | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) 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 {