Ah Ha!!! Yes, that is it. Thanks! On Mon, Nov 10, 2014 at 8:49 AM, Guozhang Wang <wangg...@gmail.com> wrote:
> Joe, > > Are you looking for this? > > > /** <code>retries</code> */ > public static final String RETRIES_CONFIG = "retries"; > > Guozhang > > On Mon, Nov 10, 2014 at 8:11 AM, Joe Stein <joe.st...@stealth.ly> wrote: > > > In the new Java producer I see that you can set RETRY_BACKOFF_MS_CONFIG > > > > > https://github.com/apache/kafka/blob/0.8.2/clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java#L112 > > which is used > > > > > https://github.com/apache/kafka/blob/0.8.2/clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java#L217-L226 > > but > > I don't see (maybe just missing it??? I haven't spent a lot of quality > time > > with the code yet) how to set the number of retry this happens before > > failure as we have in the existing producer > > > > > https://github.com/apache/kafka/blob/0.8.2/core/src/main/scala/kafka/producer/ProducerConfig.scala#L98 > > or is this done another way or no longer required or used??? > > > > /******************************************* > > Joe Stein > > Founder, Principal Consultant > > Big Data Open Source Security LLC > > http://www.stealth.ly > > Twitter: @allthingshadoop <http://www.twitter.com/allthingshadoop> > > ********************************************/ > > > > > > -- > -- Guozhang >
