
公司真题库2026-07-20
【阿里】Kafka 为什么出现重复数据,项目里怎么处理
阿里数仓实习一面真题。重复来自生产者重试、消费者位移提交与 rebalance 两个方向;项目里用幂等生产者、手动位移提交、下游幂等去重三板斧应对。
91学AI·6 阅读
共 3 篇文章

阿里数仓实习一面真题。重复来自生产者重试、消费者位移提交与 rebalance 两个方向;项目里用幂等生产者、手动位移提交、下游幂等去重三板斧应对。

回刷分口径变更、故障修复、脏数据修复、历史初始化四类场景。核心是幂等重跑、血缘联动下游、影子表双跑切换,以及与正常调度的资源隔离。

幂等解决单分区内的重复写入(PID+序列号去重),事务解决跨分区跨主题的原子写,两阶段提交 + 事务协调器,并能说出各自的边界和代价。