Return-Path: 
 <dev-return-24058-apmail-kafka-dev-archive=kafka.apache.org@kafka.apache.org>
X-Original-To: apmail-kafka-dev-archive@www.apache.org
Delivered-To: apmail-kafka-dev-archive@www.apache.org
Received: from mail.apache.org (hermes.apache.org [140.211.11.3])
	by minotaur.apache.org (Postfix) with SMTP id 188E8176D4
	for <apmail-kafka-dev-archive@www.apache.org>;
 Mon, 10 Nov 2014 16:53:25 +0000 (UTC)
Received: (qmail 34712 invoked by uid 500); 10 Nov 2014 16:53:24 -0000
Delivered-To: apmail-kafka-dev-archive@kafka.apache.org
Received: (qmail 34662 invoked by uid 500); 10 Nov 2014 16:53:24 -0000
Mailing-List: contact dev-help@kafka.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:dev-help@kafka.apache.org>
List-Unsubscribe: <mailto:dev-unsubscribe@kafka.apache.org>
List-Post: <mailto:dev@kafka.apache.org>
List-Id: <dev.kafka.apache.org>
Reply-To: dev@kafka.apache.org
Delivered-To: mailing list dev@kafka.apache.org
Received: (qmail 34640 invoked by uid 99); 10 Nov 2014 16:53:24 -0000
Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136)
    by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 10 Nov 2014 16:53:24 +0000
X-ASF-Spam-Status: No, hits=2.2 required=5.0
	tests=HTML_MESSAGE,RCVD_IN_DNSWL_LOW,SPF_NEUTRAL
X-Spam-Check-By: apache.org
Received-SPF: neutral (athena.apache.org: local policy)
Received: from [209.85.218.48] (HELO mail-oi0-f48.google.com) (209.85.218.48)
    by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 10 Nov 2014 16:53:20 +0000
Received: by mail-oi0-f48.google.com with SMTP id x69so5595530oia.7
        for <dev@kafka.apache.org>; Mon, 10 Nov 2014 08:52:14 -0800 (PST)
X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed;
        d=1e100.net; s=20130820;
        h=x-gm-message-state:mime-version:in-reply-to:references:date
         :message-id:subject:from:to:content-type;
        bh=gRzz1nwapeti5rcc+PhD0DXpN7gMAwPsN8DB5V38XJ4=;
        b=NqqdFBuAnV/MFgS1M0N+HgaBVfZhhRuipS+XvgY1F0t/3gn5VtSwnG/CLUNS4sKq0O
         fXgTQzcQZZbpavBLDvx4CXat6pZLadBgKvUHKB0H57M9i57D/zkxdua3t04wCzI4nkpt
         NH41GIGf5N4kygMX/fkXCgkPHpkl2STTh9VsYT7SwwO7+bGngJJX1j1jYzF9wyfdJadX
         WgdvGAvAIm3YFWLc4+0s6SfH+GFnx9O57f79d6MoQU2hJcE2MhWLLLExKwYPXgB4awTT
         WdXlRYKogHP8rlbLdukUhu/rNrXOR0GxSDRRrq027xxgr94sCHH7lsu0b3nkTfGc8eq7
         4ESA==
X-Gm-Message-State: 
 ALoCoQmSwTjQQeIRuXZCVcYMm/FVS7GZbAs123KZD45sd6fHrJEExN4dZOK1s/E8kR6Y3XgPNJsc
MIME-Version: 1.0
X-Received: by 10.202.196.15 with SMTP id u15mr26116210oif.21.1415638334306;
 Mon, 10 Nov 2014 08:52:14 -0800 (PST)
Received: by 10.182.158.134 with HTTP; Mon, 10 Nov 2014 08:52:14 -0800 (PST)
In-Reply-To: 
 <CAHwHRrWhZus85mxD5Z7wH-CE-uHCYVTKwSpSSTpBk12pZ2B1OQ@mail.gmail.com>
References: 
 <CAA7ooCCz-FohcVCMrNkFrcaQO=adzArzX3skv-kxfN5wzHfdUg@mail.gmail.com>
	<CAHwHRrWhZus85mxD5Z7wH-CE-uHCYVTKwSpSSTpBk12pZ2B1OQ@mail.gmail.com>
Date: Mon, 10 Nov 2014 08:52:14 -0800
Message-ID: 
 <CAA7ooCDyspx7F9iexS=p9HvM0jPu9XRSYveMaqvj4Xgivr0ZzQ@mail.gmail.com>
Subject: Re: New Java producer question
From: Joe Stein <joe.stein@stealth.ly>
To: "dev@kafka.apache.org" <dev@kafka.apache.org>
Content-Type: multipart/alternative; boundary=001a113e35ec0c1506050783fcc8
X-Virus-Checked: Checked by ClamAV on apache.org

--001a113e35ec0c1506050783fcc8
Content-Type: text/plain; charset=UTF-8

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
>

--001a113e35ec0c1506050783fcc8--