diff --git a/README.md b/README.md index ca4eb1d..33b5150 100644 --- a/README.md +++ b/README.md @@ -147,7 +147,7 @@ public class MyErrorHandler implements MqConsumeErrorHandler { | 去重 `idempotent` | ✅(需 Redis) | ✅(需 Redis) | | 失败落库 `RETRY_EXHAUSTED` | ✅ | ✅ 落库并 ACK | | 失败落库 `SINGLE` | ⚠️ 单条:落库+重投;批量:失败被吞(两端一致) | ⚠️ 单条:落库+重投;批量:失败被吞(两端一致) | -| 批量 `batchSize` | ✅ | ⚠️ 逐条回调,靠 core 内存攒批 | +| 批量 `batchSize` | ⚠️ core 内存攒批(driver 逐条喂);无 idle flush,低频停滞/重启丢未满批(两端一致) | ⚠️ core 内存攒批(driver 逐条喂);无 idle flush,低频停滞/重启丢未满批(两端一致) | | 重试 | ✅ PEL reclaim | ✅ 原生重投 | | 死信队列 | ❌ 只落库 | ✅ 原生 `%DLQ%` | | 顺序消息 | ❌ | ❌ 用的 Concurrently |