How to get broker back to ISR

2013-08-20 Thread James Wu
partition: 0 leader: 1 replicas: 0,1 isr: 1 Is there any document can explain what is the procedure to get my broker0 back to isr ? Thanks! -- -- Friendly regards, *James Wu <http://www.facebook.com/jameswu629> *

Re: How to get broker back to ISR

2013-08-21 Thread James Wu
ted, the controller broker will send it a list of > partitions that it should follow. The broker starts fetching from the > respective leaders and enters the ISR. Depending on the duration of > shutdown, the broker can take some time to enter ISR. > > Thanks, > Neha > On Aug 20, 20

Re: How to get broker back to ISR

2013-08-21 Thread James Wu
Sorry, the link is : http://mail-archives.apache.org/mod_mbox/kafka-users/201308.mbox/raw/%3CFF142F6B499AE34CAED4D263F6CA32901D34E289%40EXTXMB19.nam.nsroot.net%3E/1 On Thu, Aug 22, 2013 at 12:46 AM, James Wu wrote: > Thank you Neha. > > Actually my situation was more like this topi

Re: use kafka as dependency in sbt from central maven repository

2013-08-21 Thread James Wu
lth.ly > >>> Twitter: @allthingshadoop <http://www.twitter.com/allthingshadoop> > >>> ********/ > >>> > >>> > >>> On Tue, Aug 20, 2013 at 2:48 AM, Lorenz Knies wrote: > >>> > >>>> Hi, > >>>> > >>>> i am having problems using kafka as a dependency in sbt. > >>>> > >>>> with this simple build.sbt: > >>>> > >>>> name := "kafka-dependency-test" > >>>> > >>>> scalaVersion := "2.9.2" > >>>> > >>>> libraryDependencies += "org.apache.kafka" % "kafka_2.9.2" % > >> "0.8.0-beta1" > >>>> > >>>> > >>>> when i do > >>>> > >>>> sbt update > >>>> > >>>> i get the following error: > >>>> > >>>> sbt.ResolveException: unresolved dependency: > >>>> org.apache.kafka#kafka_2.9.2;0.8.0-beta1: null name not allowed > >>>> > >>>> i am using sbt 0.12.4 but also tried other versions with no luck > >>>> > >>>> looks like the ivy implementation ignores the org and name attributes > >> for > >>>> the zookeeper dependency in the custom inline xml included in kafkas > >>>> Build.scala > >>>> > >>>> anybody else having these problems and maybe some advice for a > >>>> solution/workaround? > >>>> > >>>> > >>>> regards > >>>> > >>>> lorenz > >>>> > >>>> > >> > >> > > -- -- Friendly regards, *James Wu <http://www.facebook.com/jameswu629> *+886.922.199.680

Questions about the leader election

2013-08-22 Thread James Wu
Hi, I am wondering what is the mechanism that Kafka elects the leader of partitions ? Does it handle by the controller process or ? If the leader crashed, who will decide the new leader ? and the process is running on Zookeeper or Kafka? Thanks. -- -- Friendly regards, *James Wu <h

Re: Questions about the leader election

2013-08-23 Thread James Wu
t; > Thanks, > Neha > > > On Thu, Aug 22, 2013 at 8:51 PM, James Wu wrote: > > > Hi, > > > > I am wondering what is the mechanism that Kafka elects the leader of > > partitions ? > > > > Does it handle by the controller process or ? > > I

Re: questions about ISR

2013-08-26 Thread James Wu
it try to catch up to go > > > back to ISR itself? > > > Or do we have to restart it? > > > > > > We can increase replica.lag.time.max.ms and replica.lag.max.messages > > > to let brokers stay longer in ISR. Is that good practice? Still this > > > is related to the first questions. We want to know what happens after > > > a broker falls out of ISR and what we should do. Thanks. > > > > > > > > > Regards, > > > > > > Libo > > > > > > > > > -- Friendly regards, *James Wu <https://plus.google.com/u/0/100829801349304669533> *