rwadurian/backend/services/mining-wallet-service/src/infrastructure/kafka/consumers
hailin 38ee808239 fix(wallet): 池余额不足时跳过 Kafka 消息,避免无限重试
BurnConsumer 和 MiningDistributionConsumer 在池余额为 0 时抛出
Insufficient pool balance 错误导致 offset 不提交,造成无限重试。
现改为记录 warn 日志并标记事件为已处理(带 :skipped:insufficient_balance 标记)。

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
2026-02-03 03:28:34 -08:00
..
burn.consumer.ts fix(wallet): 池余额不足时跳过 Kafka 消息,避免无限重试 2026-02-03 03:28:34 -08:00
contribution-distribution.consumer.ts feat(contribution): implement TEAM_BONUS backfill when unlock conditions met 2026-01-13 23:58:54 -08:00
manual-mining.consumer.ts feat(mining): 实现手工补发挖矿功能 2026-01-18 03:50:03 -08:00
mining-distribution.consumer.ts fix(wallet): 池余额不足时跳过 Kafka 消息,避免无限重试 2026-02-03 03:28:34 -08:00
pool-account-deposit.consumer.ts feat(pool-account): 实现池账户区块链充值检测和提现功能 2026-02-03 01:34:06 -08:00
user-registered.consumer.ts fix(mining-wallet): fix Kafka consumers not subscribing to topics 2026-01-13 23:31:31 -08:00