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 8621E9B29 for ; Mon, 5 Mar 2012 03:53:33 +0000 (UTC) Received: (qmail 95860 invoked by uid 500); 5 Mar 2012 03:53:33 -0000 Delivered-To: apmail-incubator-kafka-dev-archive@incubator.apache.org Received: (qmail 95767 invoked by uid 500); 5 Mar 2012 03:53:33 -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 95455 invoked by uid 99); 5 Mar 2012 03:53:27 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 05 Mar 2012 03:53:27 +0000 X-ASF-Spam-Status: No, hits=-2000.0 required=5.0 tests=ALL_TRUSTED,T_RP_MATCHES_RCVD X-Spam-Check-By: apache.org Received: from [140.211.11.116] (HELO hel.zones.apache.org) (140.211.11.116) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 05 Mar 2012 03:53:25 +0000 Received: from hel.zones.apache.org (hel.zones.apache.org [140.211.11.116]) by hel.zones.apache.org (Postfix) with ESMTP id E6E91897F for ; Mon, 5 Mar 2012 03:53:03 +0000 (UTC) Date: Mon, 5 Mar 2012 03:53:03 +0000 (UTC) From: "Prashanth Menon (Commented) (JIRA)" To: kafka-dev@incubator.apache.org Message-ID: <933201315.21388.1330919583962.JavaMail.tomcat@hel.zones.apache.org> Subject: [jira] [Commented] (KAFKA-49) Add acknowledgement to the produce request. MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 X-Virus-Checked: Checked by ClamAV on apache.org [ https://issues.apache.org/jira/browse/KAFKA-49?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13222156#comment-13222156 ] Prashanth Menon commented on KAFKA-49: -------------------------------------- Hey all. Getting the acknowledgements done was fairly straightforward - I've "todo-ed" actually waiting for replica acknowledgements as part of kafka-44 when it introduces true replicas and partitions. Having the sync producer wait for a response when it requires acknowledgements was trivial. My question is what to do with the async producer. Was the intent to perform some logic in the default event handler, or to expect clients to write custom event handlers that deal errors? Should we bubble up the response to the producer level? > Add acknowledgement to the produce request. > ------------------------------------------- > > Key: KAFKA-49 > URL: https://issues.apache.org/jira/browse/KAFKA-49 > Project: Kafka > Issue Type: Bug > Reporter: Jun Rao > Assignee: Prashanth Menon > > Currently, the produce request doesn't get acknowledged. We need to have a broker send a response to the producer and have the producer wait for the response before sending the next request. -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa For more information on JIRA, see: http://www.atlassian.com/software/jira