BurnConsumer 和 MiningDistributionConsumer 在池余额为 0 时抛出 Insufficient pool balance 错误导致 offset 不提交,造成无限重试。 现改为记录 warn 日志并标记事件为已处理(带 :skipped:insufficient_balance 标记)。 Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com> |
||
|---|---|---|
| .. | ||
| kafka | ||
| persistence | ||
| redis | ||
| infrastructure.module.ts | ||