消息队列怎么保证消息不丢失、不重复消费?多分区下怎么保证顺序?

一句话速记:消息防丢失依赖全链路保障:生产端配置 acks=all 并开启重试,Broker 端开启多副本同步复制(min.insync.replicas >= 2),消费端处理完成后手动提交 offset;消息去重本质是在至少一次(At-Least-Once)交付下由消费端实现业务幂等(如唯一键或状态机校验);多分区保序通常基于业务键进行哈希路由使其落入同一分区,消费端针对单分区进行串行消费。

消息队列

同章节的其他八股