From 3f2922cca6177a0dfbd0a2b436b208b897e07e71 Mon Sep 17 00:00:00 2001 From: hailin Date: Tue, 9 Dec 2025 03:40:14 -0800 Subject: [PATCH] fix(mpc-service): reduce rebalanceTimeout from 5min to 1min MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit sessionTimeout remains at 5 minutes (needed for long MPC operations), but rebalanceTimeout only affects joining consumer group, not processing. 🤖 Generated with [Claude Code](https://claude.com/claude-code) Co-Authored-By: Claude Opus 4.5 --- .../infrastructure/messaging/kafka/event-consumer.service.ts | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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..81bc6453 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 @@ -70,7 +70,7 @@ export class EventConsumerService implements OnModuleInit, OnModuleDestroy { sessionTimeout: 300000, // 5 minutes - MPC keygen can take a while heartbeatInterval: 10000, // 10 seconds maxWaitTimeInMs: 5000, - rebalanceTimeout: 300000, // 5 minutes + rebalanceTimeout: 60000, // 1 minute - just for joining group, not for processing }); try {