docs: 补多环境隔离跨 driver 差异与 redis-stream.* 底层配置表
- README 能力矩阵新增「多环境隔离」行:redis-stream 经底层 starter 拼 topic_env 后缀, rocketmq 无对应机制;切换 mq.type 须知从两条扩为三条(隔离静默消失)。 - 配置项一节把「redis-stream.* 一般不用动」一句扩成完整表格(env-isolation/env/ read-count/block-ms/consumer-name/max-retry/trim/autoclaim),并标明 trim/autoclaim 只认中间件自己的 handler、对 mq-starter 不生效。 - CLAUDE.md 驱动差异清单同步。 Co-Authored-By: Claude Fable 5 <noreply@anthropic.com>
This commit is contained in:
@@ -37,7 +37,7 @@ mq-starter-rocketmq RocketMQ driver(收发 + 原生重试/死信 + RET
|
||||
mq-spring-boot-starter 聚合 jar,业务方只引这一个(恒含 idempotent-redis)
|
||||
```
|
||||
|
||||
> ⚠️ **两个 driver 仍有差异**(README 有对照表):去重、失败落库、tag 过滤三者两端已对齐(2026-07 起 rocketmq `idempotent=true` 生效、需 Redis 可达;tag:rocketmq broker 原生 / redis-stream 消费端模拟,语义子集见 core 的 `MqTagMatcher`,dispatch 顶部与 reclaim 耗尽分支前两处调用);剩余差距是死信模型(redis 只落库 / rocketmq 原生 `%DLQ%`)与批量**整批失败**的处理(逐条 ACK 后无法精确重投整批,故落库+吞掉);真正两端都未兑现的只有 `concurrency`。批量攒批本身(含 idle flush 超时/停机强刷,2026-07 已落地)两端已对齐。改跨 driver 行为前先对照 README 能力表。
|
||||
> ⚠️ **两个 driver 仍有差异**(README 有对照表):去重、失败落库、tag 过滤三者两端已对齐(2026-07 起 rocketmq `idempotent=true` 生效、需 Redis 可达;tag:rocketmq broker 原生 / redis-stream 消费端模拟,语义子集见 core 的 `MqTagMatcher`,dispatch 顶部与 reclaim 耗尽分支前两处调用);剩余差距是死信模型(redis 只落库 / rocketmq 原生 `%DLQ%`)、批量**整批失败**的处理(逐条 ACK 后无法精确重投整批,故落库+吞掉)与**多环境隔离**(redis-stream 经底层 starter 的 `redis-stream.env-isolation`/`env` 拼 `topic_env` 后缀;rocketmq 无对应机制,切换后隔离静默消失);真正两端都未兑现的只有 `concurrency`。批量攒批本身(含 idle flush 超时/停机强刷,2026-07 已落地)两端已对齐。改跨 driver 行为前先对照 README 能力表。
|
||||
>
|
||||
> **单独只引 `mq-starter-rocketmq`(不走聚合坐标)时去重需自行加 `mq-starter-idempotent-redis` 依赖**——rocketmq 模块本身不依赖它(刻意零耦合)。
|
||||
|
||||
|
||||
Reference in New Issue
Block a user