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 50C7E10FC9 for ; Tue, 20 Aug 2013 20:11:09 +0000 (UTC) Received: (qmail 38360 invoked by uid 500); 20 Aug 2013 20:11:09 -0000 Delivered-To: apmail-kafka-users-archive@kafka.apache.org Received: (qmail 38340 invoked by uid 500); 20 Aug 2013 20:11:08 -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 38327 invoked by uid 99); 20 Aug 2013 20:11:08 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 20 Aug 2013 20:11:08 +0000 X-ASF-Spam-Status: No, hits=-0.7 required=5.0 tests=RCVD_IN_DNSWL_LOW,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: domain of libo.yu@citi.com designates 67.231.145.106 as permitted sender) Received: from [67.231.145.106] (HELO mx0a-00123c01.pphosted.com) (67.231.145.106) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 20 Aug 2013 20:11:00 +0000 Received: from pps.filterd (m0030125 [127.0.0.1]) by mx0a-00123c02.pphosted.com (8.14.5/8.14.5) with SMTP id r7KK1uW0008182 for ; Tue, 20 Aug 2013 20:10:38 GMT Received: from mail.citigroup.com ([192.193.220.21]) by mx0a-00123c02.pphosted.com with ESMTP id 1e5gq644d9-1 (version=TLSv1/SSLv3 cipher=AES256-SHA bits=256 verify=NOT) for ; Tue, 20 Aug 2013 20:10:38 +0000 Received: from imbhub-mw34.nam.nsroot.net (namdlpdimpgt04.nam.nsroot.net [169.193.226.13]) by smtpinbound.citigroup.com (Sentrion-MTA-4.2.2/Sentrion-MTA-4.2.2) with ESMTP id r7KK9afV018852 for ; Tue, 20 Aug 2013 20:10:37 GMT Received: from exnjiht02.nam.nsroot.net (EXNJIHT02.nam.nsroot.net [150.110.165.228]) by imbhub-mw34.nam.nsroot.net (Sentrion-MTA-4.2.2/Sentrion-MTA-4.2.2) with ESMTP id r7KKAWSP013881 for ; Tue, 20 Aug 2013 20:10:33 GMT Received: from EXNJIHT05.nam.nsroot.net (150.110.191.40) by exnjiht02.nam.nsroot.net (150.110.165.228) with Microsoft SMTP Server (TLS) id 8.3.264.0; Tue, 20 Aug 2013 16:10:26 -0400 Received: from EXTXHT06.nam.nsroot.net (169.177.87.43) by EXNJIHT05.nam.nsroot.net (150.110.191.40) with Microsoft SMTP Server (TLS) id 14.2.328.9; Tue, 20 Aug 2013 16:10:23 -0400 Received: from EXTXMB19.nam.nsroot.net ([169.254.4.20]) by EXTXHT06.nam.nsroot.net ([169.177.87.43]) with mapi id 14.02.0328.009; Tue, 20 Aug 2013 15:10:22 -0500 From: "Yu, Libo " To: "'users@kafka.apache.org'" Subject: RE: issue with kafka-preferred-replica-election.sh Thread-Topic: issue with kafka-preferred-replica-election.sh Thread-Index: AQHOnd9b6Nn3QKNrTkqheUkOTDRMVZmehPUw Date: Tue, 20 Aug 2013 20:10:21 +0000 Message-ID: References: In-Reply-To: Accept-Language: en-US Content-Language: en-US X-MS-Has-Attach: X-MS-TNEF-Correlator: x-originating-ip: [169.177.87.240] Content-Type: text/plain; charset="us-ascii" Content-Transfer-Encoding: quoted-printable MIME-Version: 1.0 X-WiganSS: 01000000010018EXNJIHT05.nam.nsroot.net ID0042 X-CFilter-Loop: Reflected X-Proofpoint-Virus-Version: vendor=fsecure engine=2.50.10432:5.10.8794,1.0.431,0.0.0000 definitions=2013-08-20_08:2013-08-20,2013-08-20,1970-01-01 signatures=0 X-Virus-Checked: Checked by ClamAV on apache.org Hi Guozhang, Thanks for the detailed reply. All the brokers are running. The path not created is /brokers/topics/uattoqaaa.default/partitions not /brokers/topics/uattoqaaa.default/partitions/[partition-id]/state Actually, I found quite a few topics don't have the issue. The controller=20 must have failed to create them. I will keep monitoring this issue. Currently, when /brokers/topics/my_path/partitions is not there, kafka-preferred-replica-election.sh stops right away with nonode keeper exception. Could you file a JIRA to make it keep working in that scenario?=20 Regards, Libo -----Original Message----- From: Guozhang Wang [mailto:wangguoz@gmail.com]=20 Sent: Tuesday, August 20, 2013 3:56 PM To: users@kafka.apache.org Subject: Re: issue with kafka-preferred-replica-election.sh The create command tool will only create the path /brokers/topics/uattoqaaa= .default, and then controller, once noticing the change in ZK about the add= ed topic, will elect leaders from the assigned replicas written in /brokers= /topics/uattoqaaa.default and then create /brokers/topics/uattoqaaa.default= /partitions/[partition-id]/state. If you have created the topic for a long time but /brokers/topics/uattoqaaa= .default/partitions/[partition-id]/state is not created by controller, it c= ould because the replicas specified in /brokers/topics/uattoqaaa.default do= es not exist yet. Could you verify the brokers specified in this path are u= p and running? Guozhang On Tue, Aug 20, 2013 at 12:14 PM, Yu, Libo wrote: > One more question: > "The create topic command will not immediately create the path; it=20 > will be created by the controller later during the creation of=20 > partitions and assign replicas to partitions." > > So when will the controller create the path and partitions? When the=20 > first message is published to the topic and partition? > All the partitions are created at once? > > Regards, > > Libo > > > -----Original Message----- > From: Guozhang Wang [mailto:wangguoz@gmail.com] > Sent: Tuesday, August 20, 2013 1:48 PM > To: users@kafka.apache.org > Subject: Re: issue with kafka-preferred-replica-election.sh > > Could you check that before you run=20 > kafka-preferred-replica-election.sh > the /brokers/topics/uattoqaaa.default/partitions Node has been created=20 > or not? > The create topic command will not immediately create the path; it will=20 > be created by the controller later during the creation of partitions=20 > and assign replicas to partitions. If you start the election command=20 > right after the create topic tool, it might not be created yet. > > Guozhang > > > On Tue, Aug 20, 2013 at 10:24 AM, Yu, Libo wrote: > > > It is created with 3 partitions. > > > > Regards, > > > > Libo > > > > > > -----Original Message----- > > From: Guozhang Wang [mailto:wangguoz@gmail.com] > > Sent: Tuesday, August 20, 2013 12:21 PM > > To: users@kafka.apache.org > > Subject: Re: issue with kafka-preferred-replica-election.sh > > > > Hello Libo, > > > > Before you call the kafka-preferred-replica-election.sh have you=20 > > already created the topic uattoqaaa.default with the number of > partitions? > > > > Guozhang > > > > > > On Tue, Aug 20, 2013 at 8:35 AM, Yu, Libo wrote: > > > > > Hi, > > > > > > I tried to run kafka-preferred-replica-election.sh on our kafka > cluster. > > > But I got this expection: > > > Failed to start preferred replica election > > > org.I0Itec.zkclient.exception.ZkNoNodeException: > > > org.apache.zookeeper.KeeperException$NoNodeException: > > > KeeperErrorCode =3D NoNode for > > > /brokers/topics/uattoqaaa.default/partitions > > > > > > I checked zookeeper and there is no=20 > > > /brokers/topics/uattoqaaa.default/partitions. All I found is=20 > > > /brokers/topics/uattoqaaa.default. > > > > > > I believe this is a bug and I am not sure if there is a JIRA for it. > > > Could you confirm? Thanks. > > > > > > Regards, > > > > > > Libo > > > > > > > > > > > > -- > > -- Guozhang > > > > > > -- > -- Guozhang > -- -- Guozhang