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 4719ADBC3 for ; Wed, 12 Sep 2012 16:40:51 +0000 (UTC) Received: (qmail 95066 invoked by uid 500); 12 Sep 2012 16:40:49 -0000 Delivered-To: apmail-incubator-kafka-dev-archive@incubator.apache.org Received: (qmail 95034 invoked by uid 500); 12 Sep 2012 16:40:49 -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 95002 invoked by uid 99); 12 Sep 2012 16:40:49 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 12 Sep 2012 16:40:49 +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 jjkoshy.w@gmail.com designates 209.85.210.175 as permitted sender) Received: from [209.85.210.175] (HELO mail-iy0-f175.google.com) (209.85.210.175) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 12 Sep 2012 16:40:43 +0000 Received: by iaky10 with SMTP id y10so1513908iak.6 for ; Wed, 12 Sep 2012 09:40:22 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=mime-version:in-reply-to:references:date:message-id:subject:from:to :content-type; bh=KvDFEaxD6bYJl1TmmAx/VVR1p0tUzWK7ND6ukX3cNYE=; b=B9G1OYJ+Uf3HMNwC0JTkghOLXn8bbqJ09YWd7FmSSH2EmM9pxqvZ4HS1nr95zdMSFq lps5QKw8ApoCkr8lHMCHlviEbKT0r/CwXP7YVCpADRCOvJORY4TqUg6kuc/Cm5VUZ/Mi O616/Cs6bq05ZrZdq9PtBF8kI7dFuFVdcH+QT/KR/UzV3X7ndOyuxGCuKXn4og0VYuid 1uilNvjYUgRpjpE5R9Xvs72kBO4unG2K3/FSv2vfAZilSup88djLByVlJf0nrYJ7vUQx TtvGP0CJ2Q36HgpmMYpC2CRyfWwya/vvX6CdinZaHNwkTIdneq+/GKHU01AyPeYKTtY5 hMlA== MIME-Version: 1.0 Received: by 10.50.85.226 with SMTP id k2mr21531668igz.61.1347468022347; Wed, 12 Sep 2012 09:40:22 -0700 (PDT) Received: by 10.50.1.211 with HTTP; Wed, 12 Sep 2012 09:40:22 -0700 (PDT) In-Reply-To: References: Date: Wed, 12 Sep 2012 09:40:22 -0700 Message-ID: Subject: Re: PartitionData From: Joel Koshy To: kafka-dev@incubator.apache.org Content-Type: multipart/alternative; boundary=e89a8f3bb005d176e404c983d873 X-Virus-Checked: Checked by ClamAV on apache.org --e89a8f3bb005d176e404c983d873 Content-Type: text/plain; charset=ISO-8859-1 That's a good point. I did notice that while working on KAFKA-391. The idea behind it must have been that both producer and fetch requests deal with actual partition data. However, the hw and error code don't make sense on the request side. I can include this change as part of KAFKA-391 if that makes sense. Joel On Wed, Sep 12, 2012 at 9:32 AM, Jay Kreps wrote: > Hey Guys, > > The request format in 0.8 has drifted a bit from the proposal ( > https://cwiki.apache.org/confluence/display/KAFKA/New+Wire+Format+Proposal > ). > A lot of this was new fields that were needed. But some oddities have > slipped in. > > For example we are reusing PartitionData.scala in both the produce request > and the fetch response. This seems like clever code reuse, but in reality > it changes the protocol to add a bunch of non-sensical fields into the > request format. For example in a request one now has to specify a error > code, and initial offset, and a high water mark! > > Is this intentional? I recommend we change this before the release. > Thoughts? > > -Jay > --e89a8f3bb005d176e404c983d873--