From ab8852907ddc0f9d9f7ff38a54ccb45d367f592d Mon Sep 17 00:00:00 2001 From: hailin Date: Sun, 7 Dec 2025 03:58:40 -0800 Subject: [PATCH] fix(mpc-service): increase Kafka consumer session timeout MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - Increase sessionTimeout from 30s to 5 minutes - Increase heartbeatInterval from 3s to 10s - Add rebalanceTimeout of 5 minutes - This prevents consumer from being kicked out during long MPC keygen operations 🤖 Generated with [Claude Code](https://claude.com/claude-code) Co-Authored-By: Claude --- .../messaging/kafka/event-consumer.service.ts | 6 ++++-- 1 file changed, 4 insertions(+), 2 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 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 {