Return-Path: X-Original-To: apmail-incubator-kafka-dev-archive@minotaur.apache.org Delivered-To: apmail-incubator-kafka-dev-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 593CE651A for ; Thu, 21 Jul 2011 22:34:17 +0000 (UTC) Received: (qmail 25907 invoked by uid 500); 21 Jul 2011 22:34:17 -0000 Delivered-To: apmail-incubator-kafka-dev-archive@incubator.apache.org Received: (qmail 25865 invoked by uid 500); 21 Jul 2011 22:34:16 -0000 Mailing-List: contact kafka-dev-help@incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: kafka-dev@incubator.apache.org Delivered-To: mailing list kafka-dev@incubator.apache.org Received: (qmail 25857 invoked by uid 99); 21 Jul 2011 22:34:16 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 21 Jul 2011 22:34:16 +0000 X-ASF-Spam-Status: No, hits=4.0 required=5.0 tests=FREEMAIL_FROM,FREEMAIL_REPLY,HTML_MESSAGE,RCVD_IN_DNSWL_LOW,SPF_PASS,T_TO_NO_BRKTS_FREEMAIL X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: domain of junrao@gmail.com designates 74.125.82.43 as permitted sender) Received: from [74.125.82.43] (HELO mail-ww0-f43.google.com) (74.125.82.43) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 21 Jul 2011 22:34:08 +0000 Received: by wwi18 with SMTP id 18so1571357wwi.0 for ; Thu, 21 Jul 2011 15:33:48 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=gamma; h=mime-version:in-reply-to:references:date:message-id:subject:from:to :content-type; bh=7fAE2ACpyUXZsPMmfiEWwGfPyiTghBI2vWhFGFnawdk=; b=Rqlzkdxr1x60H3TwlBp/JcwyZmFCVXC31luvYfzY7ZONeYQcN9Te5ITRb4PpYt8QyY iyxt3h2qpMOWOK1y+O9gwNHSj9OoqGAjfe2eWoeDpmekGzTWyKkJRa7I7o1irTuHXH3Y wDgByqlsRv7xdfR8okKinPtRfiGgw9mIPvVm0= MIME-Version: 1.0 Received: by 10.216.66.149 with SMTP id h21mr596836wed.103.1311287628173; Thu, 21 Jul 2011 15:33:48 -0700 (PDT) Received: by 10.216.93.139 with HTTP; Thu, 21 Jul 2011 15:33:48 -0700 (PDT) In-Reply-To: References: Date: Thu, 21 Jul 2011 15:33:48 -0700 Message-ID: Subject: Re: kafka-49 From: Jun Rao To: kafka-dev@incubator.apache.org Content-Type: multipart/alternative; boundary=000e0ce0d8ac46911604a89bf1aa X-Virus-Checked: Checked by ClamAV on apache.org --000e0ce0d8ac46911604a89bf1aa Content-Type: text/plain; charset=ISO-8859-1 If we have ACK, the producer can catch any exception and resend. Jun On Thu, Jul 21, 2011 at 12:47 PM, Jay Kreps wrote: > Yeah, that makes sense. How are we going to handle production through a vip > in that case? > > -Jay > > On Thu, Jul 21, 2011 at 7:44 AM, Jun Rao wrote: > > > Without replication, we can make ACK optional. With replication, a > producer > > can only write to the leader replica. Without ACK, there is no way that > the > > broker can inform the producer that it's trying to write to the wrong > > broker. > > > > Jun > > > > On Wed, Jul 20, 2011 at 8:58 PM, Jay Kreps wrote: > > > > > It might be nice to consider making the ack optional and part of the > > > request. The current behavior is good for many uses, the request is > > > instantaneously written to the socket buffer but sent asynchronously. I > > > think that is a valuable use case where you care about throughput. I > > guess > > > the question is whether the asynchronous api already covers that well > > > enough > > > and how much complexity exposing that causes. > > > > > > -Jay > > > > > > On Wed, Jul 20, 2011 at 5:51 PM, Jun Rao wrote: > > > > > > > Jeff, > > > > > > > > I was thinking of making the ACK mandatory for the producer. The ACK > > can > > > be > > > > sent when the message either hits 1 replicas or multiple replicas, > > > > depending > > > > on the setting. > > > > > > > > Having the ACK include the starting offset of the message seems > > > reasonable. > > > > It will be a bit complicated for multisend since multiple offsets > have > > to > > > > be > > > > returned. What do you need the offset for? > > > > > > > > Thanks, > > > > > > > > Jun > > > > > > > > On Wed, Jul 20, 2011 at 12:47 PM, Jeffrey Damick < > > > jeffreydamick@gmail.com > > > > >wrote: > > > > > > > > > Is there any current thought around KAFKA-49, for acknowledgement > of > > > > > producers? > > > > > Will this be optional, a new message type(s)? > > > > > Will the ack be synchronous or asynchronous or depending on request > > > type? > > > > > > > > > > It would be fantastic if the ack contained the starting offset of > the > > > > > message published, and not just the ending. > > > > > > > > > > This is quickly becoming an issue for us, so we may be able to > > provide > > > > some > > > > > help in this area.. > > > > > > > > > > > > > > > thanks > > > > > -jeff > > > > > > > > > > > > > > > --000e0ce0d8ac46911604a89bf1aa--