kafka事务性之幂等性的实现

producer幂等性 kafka的幂等性是指在发送同一条消息时,在服务端只会被持久化一次,数据不丢不重。 可是是有条件的 1:kafka的幂等性只能保证单会话有效,若是broker挂掉重启,幂等就无效了,由于没法获取以前的状态信息 2:幂等性不能跨多个Topic-Partition,只能保证单个partition的幂等性。web 若是须要跨分区实现幂等就只能借助事务性实现,下一篇就会结束kafk
相关文章
相关标签/搜索