1 个回答
kafka Producer的幂等性是指，发送同一条消息时，数据在Server端只会被持久化一次，数据不丢不重。但这里的幂等性时有条件的：
1、只能保证producer在单个会话内不重不丢，如果producer出现意外挂掉再重启时无法保证的幂等性情况下，是无法获取之前的状态信息，因此无法做到跨会话级别不重不丢
2、幂等性不能跨多个topic-partition，只能保证单个partition内的幂等性，当设计到多个时，这中间的状态并没有同步，如果要跨会话，跨多个partition的情况下，需要kafka的事务来实现发布于：3个月前 (01-24) IP属地：四川省
我来回答
您需要 登录 后回答此问题！