diff --git a/backend/services/mining-blockchain-service/src/infrastructure/kafka/adoption-injection-consumer.service.ts b/backend/services/mining-blockchain-service/src/infrastructure/kafka/adoption-injection-consumer.service.ts index ccb8d4fa..0c83c68a 100644 --- a/backend/services/mining-blockchain-service/src/infrastructure/kafka/adoption-injection-consumer.service.ts +++ b/backend/services/mining-blockchain-service/src/infrastructure/kafka/adoption-injection-consumer.service.ts @@ -139,6 +139,16 @@ export class AdoptionInjectionConsumerService implements OnModuleInit, OnModuleD return; } + // 双保险:丢弃 2026-03-10 前的事件,防止历史积压消息触发意外注入 + const CUTOFF_DATE = new Date('2026-03-10T00:00:00+08:00'); + const eventCreatedAt = parsed.created_at ? new Date(parsed.created_at) : null; + if (!eventCreatedAt || eventCreatedAt < CUTOFF_DATE) { + this.logger.warn( + `[SKIP] AdoptionFusdtInjectionRequested event discarded: created_at=${parsed.created_at} is before cutoff ${CUTOFF_DATE.toISOString()}`, + ); + return; + } + this.logger.log(`[RECEIVE] AdoptionFusdtInjectionRequested event received`); this.logger.log(`[RECEIVE] offset=${message.offset}, partition=${partition}`);