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 049A2C7E5 for ; Mon, 11 Jun 2012 23:52:54 +0000 (UTC) Received: (qmail 985 invoked by uid 500); 11 Jun 2012 23:52:53 -0000 Delivered-To: apmail-incubator-kafka-dev-archive@incubator.apache.org Received: (qmail 949 invoked by uid 500); 11 Jun 2012 23:52:53 -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 938 invoked by uid 99); 11 Jun 2012 23:52:53 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 11 Jun 2012 23:52:53 +0000 X-ASF-Spam-Status: No, hits=1.5 required=5.0 tests=HTML_MESSAGE,RCVD_IN_DNSWL_LOW,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (athena.apache.org: domain of neha.narkhede@gmail.com designates 209.85.160.175 as permitted sender) Received: from [209.85.160.175] (HELO mail-gh0-f175.google.com) (209.85.160.175) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 11 Jun 2012 23:52:47 +0000 Received: by ghbz2 with SMTP id z2so2828304ghb.6 for ; Mon, 11 Jun 2012 16:52:26 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=mime-version:date:message-id:subject:from:to:content-type; bh=2/RBuKEkHM06zo8sypKHDOPwWsNRboCX0Nm+6WMPXjc=; b=bfnSiBjHSrS0M1g2oTx1/O7LN3YFXBbMnxFPNyjmDVXExAgGII7TFtBCeLo4cjFScQ rKB79wmD+BD4O5ZjjTmC4eN9ATJwBJsLnZISJd64h+Vomw+aB8jabrW37+vZEv2RiUUO SI81YpXDvyjAyhWBfNiY5YKfdNcVK/9WwlkCcAln0sOZQFfTX24UxYHqhsta6+kCBFgB Rb0TlJW0s/X0ZkkcTXnWL1bFwk+Eeu63zipvXo/Nudmv/j+BmyB7yFjpUbT671HBZVBC AT69dm59L3cuS3iShwZqFUWC8EPBvDq8jt0gekdko7oXQXIKFHLdf1lv0aGSgYSolrpr qM1w== MIME-Version: 1.0 Received: by 10.50.216.234 with SMTP id ot10mr7362968igc.51.1339458746500; Mon, 11 Jun 2012 16:52:26 -0700 (PDT) Received: by 10.64.24.166 with HTTP; Mon, 11 Jun 2012 16:52:26 -0700 (PDT) Date: Mon, 11 Jun 2012 16:52:26 -0700 Message-ID: Subject: Consumer re-design proposal From: Neha Narkhede To: kafka-users@incubator.apache.org, kafka-dev@incubator.apache.org Content-Type: multipart/alternative; boundary=f46d040167a9c6c51604c23b0a8d X-Virus-Checked: Checked by ClamAV on apache.org --f46d040167a9c6c51604c23b0a8d Content-Type: text/plain; charset=ISO-8859-1 Hi, Over the past few months, we've received quite a lot of feedback on the consumer side features and design. Some of them are improvements to the current consumer design and some are simply new feature/API requests. I have attempted to write up the requirements that I've heard on this wiki - https://cwiki.apache.org/confluence/display/KAFKA/Consumer+Client+Re-Design This would involve some significant changes to the consumer APIs, so we would like to collect feedback on the proposal from our community. Since the list of changes is not small, we would like to understand if some features are preferred over others, and more importantly, if some features are not required at all. Since some part of this proposal is experimental and the consumer side changes are non-trivial, we would like this initiative to not interfere with the forthcoming replication release. However, it will be good to have people from the community give this some thought and help out with the JIRAs if interested. One way of managing this project could be creating a separate branch from the kafka trunk and continue development on it. Once it is ready and in good shape, we can think about cutting another release (after 0.8) for the releasing the new consumer API. Do people have preferences/concerns regarding creating a separate branch for this project ? Please feel free to start a discussion on this JIRA - https://issues.apache.org/jira/browse/KAFKA-364 Thanks, Neha --f46d040167a9c6c51604c23b0a8d--