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
