You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@kafka.apache.org by Xiaoyu Wang <xw...@rocketfuel.com> on 2015/01/08 23:55:45 UTC
Producer exception handling with required.ack = -1
Hi All,
Just want to double check with you regarding producers using required.acks
= -1.
- Producer is guaranteed to receive responses within certain time.
Because the satisfied request checking is for in-sync replica. If some
replica got stuck, it will be removed from in-sync replica and hence won't
block sending response back.
- All exceptions in response come from the leader replica, which means
appending to the leader failed and producer should resend the message.
- Potential data loss case: when broker does unclean-leader election
- Potential data duplication case: connection dropped before producer
receives response. In which case, producer does not know whether the
request succeeded or resend the message.
Are those above correct? Thank you for your time.
Re: Producer exception handling with required.ack = -1
Posted by gh...@gmail.com.
Yes. That's correct.
Thanks,
Mayuresh
Sent from my iPhone
> On Jan 8, 2015, at 2:55 PM, Xiaoyu Wang <xw...@rocketfuel.com> wrote:
>
> Hi All,
>
> Just want to double check with you regarding producers using required.acks
> = -1.
>
> - Producer is guaranteed to receive responses within certain time.
> Because the satisfied request checking is for in-sync replica. If some
> replica got stuck, it will be removed from in-sync replica and hence won't
> block sending response back.
>
>
> - All exceptions in response come from the leader replica, which means
> appending to the leader failed and producer should resend the message.
>
>
> - Potential data loss case: when broker does unclean-leader election
>
>
> - Potential data duplication case: connection dropped before producer
> receives response. In which case, producer does not know whether the
> request succeeded or resend the message.
>
> Are those above correct? Thank you for your time.