From users-return-2864-apmail-kafka-users-archive=kafka.apache.org@kafka.apache.org Mon Dec 10 18:09:49 2012 Return-Path: X-Original-To: apmail-kafka-users-archive@www.apache.org Delivered-To: apmail-kafka-users-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id DD960D44A for ; Mon, 10 Dec 2012 18:09:48 +0000 (UTC) Received: (qmail 69297 invoked by uid 500); 10 Dec 2012 18:09:48 -0000 Delivered-To: apmail-kafka-users-archive@kafka.apache.org Received: (qmail 69274 invoked by uid 500); 10 Dec 2012 18:09:48 -0000 Mailing-List: contact users-help@kafka.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: users@kafka.apache.org Delivered-To: mailing list users@kafka.apache.org Received: (qmail 69266 invoked by uid 99); 10 Dec 2012 18:09:48 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 10 Dec 2012 18:09:48 +0000 X-ASF-Spam-Status: No, hits=-0.0 required=5.0 tests=SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: local policy) Received: from [65.216.151.118] (HELO mailgtwy.bit-sys.com) (65.216.151.118) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 10 Dec 2012 18:09:42 +0000 From: "Sybrandy, Casey" To: "users@kafka.apache.org" Subject: RE: Logging which broker a message was sent to Thread-Topic: Logging which broker a message was sent to Thread-Index: Ac3W6rLfowRjiLJLQ66Pr+xXYn8MPgAL7oIA//+skVKAAHQhAP//rVlo Date: Mon, 10 Dec 2012 18:09:20 +0000 Message-ID: <1ADF2328684F7B4BBA92DB930825BE68574BB607@suhn-mbx2.SIX3.local> References: <1ADF2328684F7B4BBA92DB930825BE68574BB4AB@suhn-mbx2.SIX3.local> <1ADF2328684F7B4BBA92DB930825BE68574BB511@suhn-mbx2.SIX3.local>, In-Reply-To: Accept-Language: en-US Content-Language: en-US X-MS-Has-Attach: X-MS-TNEF-Correlator: Content-Type: text/plain; charset="us-ascii" Content-Transfer-Encoding: quoted-printable MIME-Version: 1.0 Received-SPF: none X-Virus-Checked: Checked by ClamAV on apache.org I'll try that out. Thanks!=0A= =0A= ________________________________________=0A= From: Jun Rao [junrao@gmail.com]=0A= Sent: Monday, December 10, 2012 1:04 PM=0A= To: users@kafka.apache.org=0A= Subject: Re: Logging which broker a message was sent to=0A= =0A= So, you are using Producer, not SyncProducer. Assuming that you are using= =0A= DefaultEventHandler, there is a trace level logging that tells you which=0A= broker a request is sent to.=0A= =0A= Thanks,=0A= =0A= Jun=0A= =0A= On Mon, Dec 10, 2012 at 8:10 AM, Sybrandy, Casey <=0A= Casey.Sybrandy@six3systems.com> wrote:=0A= =0A= > Is it at least possible to see which broker a message is sent to? I'm=0A= > using a Zookeeper based producer and we have multiple brokers in our=0A= > environment. If I can tell which broker a message is sent to, that would= =0A= > be a big help.=0A= >=0A= > ________________________________________=0A= > From: Jun Rao [junrao@gmail.com]=0A= > Sent: Monday, December 10, 2012 11:07 AM=0A= > To: users@kafka.apache.org=0A= > Subject: Re: Logging which broker a message was sent to=0A= >=0A= > If you use -1 (ie, a random partition) as the partition #, there is no ea= sy=0A= > way to know which partition that the broker picks. However, you can=0A= > explicitly specify the partition # in the request itself.=0A= >=0A= > Thanks,=0A= >=0A= > Jun=0A= >=0A= > On Mon, Dec 10, 2012 at 7:26 AM, Sybrandy, Casey <=0A= > Casey.Sybrandy@six3systems.com> wrote:=0A= >=0A= > > Is it possible to log/see which broker, and perhaps partition, a produc= er=0A= > > sent a message to? I'm using the SyncProducer if that matters.=0A= > >=0A= >=0A=