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