Thanks Robert, For #2 Yes Robert, I am using kafka-server-stop.sh script to stop Brokers and it all resides on same Host with different port.
Is there any way to avoid/prevent shutdown of all brokers ? Thanks for you kind response! On Mon, Jun 2, 2014 at 10:37 PM, Robert Hodges <berkeleybob2...@gmail.com> wrote: > Hi Rafeeq, > > With respect to question #2, are you stopping brokers using > kafka-server-stop.sh and are they all on a single host? If so, the script > finds anything that looks like a Kafka server and should knock out all the > brokers at once. If your cluster runs across multiple hosts something else > is going on. > > Cheers, Robert > > p.s., Same thing applies for the zookeeper-server-stop.sh script. > > > On Mon, Jun 2, 2014 at 10:23 AM, rafeeq s <rafeeq.ec...@gmail.com> wrote: > > > Hi > > > > I am using kafka 0.8.1 version and facing frequent issue when *kafka > > broker* > > startup/restart such as: > > > > *1.Whenever Kafka Broker restarted it gets shutdown and throws following > > error in all Broker nodes.* > > > > java.io.EOFException: Received -1 when reading from channel, socket has > > likely been closed. > > at kafka.utils.Utils$.read(Utils.scala:376) > > at > > > > > kafka.network.BoundedByteBufferReceive.readFrom(BoundedByteBufferReceive.scala:67) > > at > > kafka.network.Receive$class.readCompletely(Transmission.scala:56) > > at > > > > > kafka.network.BoundedByteBufferReceive.readCompletely(BoundedByteBufferReceive.scala:29) > > at > kafka.network.BlockingChannel.receive(BlockingChannel.scala:100) > > at > > kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:81) > > at > > > > > kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71) > > at > > > > > kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109) > > at > > > > > kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109) > > at > > > > > kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109) > > at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33) > > at > > > > > kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108) > > at > > > > > kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108) > > at > > > > > kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108) > > at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33) > > at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107) > > at > > > > > kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96) > > at > > kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88) > > at > kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) > > *or Some time it throws below error: * > > ERROR [KafkaApi-151] Error while fetching metadata for partition > [BACKUP,1] > > (kafka.server.KafkaApis) > > kafka.common.ReplicaNotAvailableException > > at > > kafka.server.KafkaApis$$anonfun$20$$anonfun$23.apply(KafkaApis.scala:589) > > at > > kafka.server.KafkaApis$$anonfun$20$$anonfun$23.apply(KafkaApis.scala:574) > > at > > > > > scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) > > at > > > > > scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) > > > > > > *2.If I stop single kafka broker, it will shutdown all other brokers in > > the cluster ?* > > > > When I try to stop single kafka Broker ,it terminates all other kafka > > brokers. > > > > Any guess why all kafka broker nodes get terminated on stop of single > > Broker ? > > > > Thanks in advance , your answer will save my time. > > >
