From 7d3483b565fd742900c988f4a3d48d9ab10647ac Mon Sep 17 00:00:00 2001 From: hailin Date: Wed, 7 Jan 2026 18:47:05 -0800 Subject: [PATCH] =?UTF-8?q?fix(referral-service):=20=E4=BF=AE=E5=A4=8D=20K?= =?UTF-8?q?afka=20=E6=B6=88=E8=B4=B9=E5=BC=82=E5=B8=B8=E8=A2=AB=E5=90=9E?= =?UTF-8?q?=E6=8E=89=E7=9A=84=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - kafka.service.ts: 抛出异常让 KafkaJS 触发重试 - user-registered.handler.ts: 传播异常到 KafkaService 修复前处理失败的消息不会重试，导致推荐关系可能丢失 🤖 Generated with [Claude Code](https://claude.com/claude-code) Co-Authored-By: Claude Opus 4.5 --- .../src/application/event-handlers/user-registered.handler.ts | 1 + .../src/infrastructure/messaging/kafka.service.ts | 1 + 2 files changed, 2 insertions(+) diff --git a/backend/services/referral-service/src/application/event-handlers/user-registered.handler.ts b/backend/services/referral-service/src/application/event-handlers/user-registered.handler.ts index f4ff3307..3402ec61 100644 --- a/backend/services/referral-service/src/application/event-handlers/user-registered.handler.ts +++ b/backend/services/referral-service/src/application/event-handlers/user-registered.handler.ts @@ -88,6 +88,7 @@ export class UserRegisteredHandler implements OnModuleInit { `Failed to create referral relationship for accountSequence=${payload.accountSequence}:`, error, ); + throw error; // 传播异常，让 Kafka 重试 } } } diff --git a/backend/services/referral-service/src/infrastructure/messaging/kafka.service.ts b/backend/services/referral-service/src/infrastructure/messaging/kafka.service.ts index e3703b04..95d3e4a9 100644 --- a/backend/services/referral-service/src/infrastructure/messaging/kafka.service.ts +++ b/backend/services/referral-service/src/infrastructure/messaging/kafka.service.ts @@ -100,6 +100,7 @@ export class KafkaService implements OnModuleInit, OnModuleDestroy { } } catch (error) { this.logger.error(`Error processing message from ${topic}:`, error); + throw error; // 让 KafkaJS 知道处理失败，触发重试 } }, });