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 9055B97FE for ; Thu, 8 Dec 2011 03:38:23 +0000 (UTC) Received: (qmail 38542 invoked by uid 500); 8 Dec 2011 03:38:23 -0000 Delivered-To: apmail-incubator-kafka-dev-archive@incubator.apache.org Received: (qmail 38501 invoked by uid 500); 8 Dec 2011 03:38:22 -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 38493 invoked by uid 99); 8 Dec 2011 03:38:22 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 08 Dec 2011 03:38:22 +0000 X-ASF-Spam-Status: No, hits=1.6 required=5.0 tests=FREEMAIL_ENVFROM_END_DIGIT,HTML_MESSAGE,RCVD_IN_DNSWL_LOW,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (athena.apache.org: domain of nnchuong411@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, 08 Dec 2011 03:38:16 +0000 Received: by wgbds11 with SMTP id ds11so4815811wgb.0 for ; Wed, 07 Dec 2011 19:37:54 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=gamma; h=mime-version:date:message-id:subject:from:to:content-type; bh=QyeQZ6bvB4o+wm2pZ6ioCj58BZwEWqWe1iR5k4FWjEA=; b=tgnsiXKQSBhGM047e/t5wCeYCxUy+htOgTS+VfI+bwhkkJCTFG9B9IDya0mEaR1tdm atg7S+hlX8ev9A7Mav7fzxTlN9S/dEI/yg4J4Ffoa7QdfExqeI0dpRtmHLLzpkR5+cim M4slRljpuS0xJbwXsPhsQVVcKuEihax1+HXbg= MIME-Version: 1.0 Received: by 10.180.107.229 with SMTP id hf5mr1717024wib.35.1323315474758; Wed, 07 Dec 2011 19:37:54 -0800 (PST) Received: by 10.227.178.10 with HTTP; Wed, 7 Dec 2011 19:37:54 -0800 (PST) Date: Thu, 8 Dec 2011 10:37:54 +0700 Message-ID: Subject: Retrieve Partition-Id from MessageStream From: nn chuong411 To: kafka-dev@incubator.apache.org Content-Type: multipart/alternative; boundary=e89a8f23567dcc7d4004b38c64d3 --e89a8f23567dcc7d4004b38c64d3 Content-Type: text/plain; charset=ISO-8859-1 Hi all, I'm using ZooKeeperConsumerConnector to create a group of messageStream. But is there anyway to retrieve partitionId associated with each messageStream? -- Nguyen Nam Chuong Software Engineer - VNG Cooperation Ho Chi Minh City - Vietnam --e89a8f23567dcc7d4004b38c64d3--