kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Libo Yu <yu_l...@hotmail.com>
Subject RE: question about synchronous producer
Date Fri, 30 May 2014 12:32:44 GMT
Thanks for your help, Guozhen.
Assume request.required.acks is set to 1 for the scenario I mentioned.   While send() is being
called, brokers are shutdown. What should I expect? 
1 send() will retry 3 times with a 100ms interval and return.
2 send will not return until the brokers are back online.

Thanks,

Libo

> Date: Thu, 29 May 2014 20:11:48 -0700
> Subject: Re: question about synchronous producer
> From: wangguoz@gmail.com
> To: users@kafka.apache.org
> 
> Libo,
> 
> That is correct. You may want to increase the retry.backoff.ms in this
> case. In practice, if the brokers are down for too long, then data loss is
> usually inevitable.
> 
> Guozhang
> 
> 
> On Thu, May 29, 2014 at 2:55 PM, Libo Yu <yu_libo@hotmail.com> wrote:
> 
> > Hi team,
> >
> > Assume I am using a synchronous producer and it has the following default
> > properties:
> >
> > message.send.max.retries
> >       3
> > retry.backoff.ms
> >       100
> >
> > I use java api Producer.send(message) to send a message.
> > While send() is being called, if the brokers are shutdown, what happens?
> > send() will retry 3 times with a 100ms interval and fail silently?
> > If I don't want to lose any message when the brokers are back online, what
> > should I do? Thanks.
> >
> > Libo
> >
> >
> >
> >
> 
> 
> 
> 
> -- 
> -- Guozhang
 		 	   		  
Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message