kafka-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Joe Stein <joe.st...@stealth.ly>
Subject Re: New Java producer question
Date Mon, 10 Nov 2014 16:52:14 GMT
Ah Ha!!! Yes, that is it. Thanks!

On Mon, Nov 10, 2014 at 8:49 AM, Guozhang Wang <wangguoz@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.stein@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
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message