Hi Rafeeq,
You can stop them individually by killing the processes. The
kafka-server-stop.sh command just uses a kill -SIGTERM if you look at the
end of the script:
ps ax | grep -i 'kafka\.Kafka' | grep java | grep -v grep | awk '{print
$1}' | xargs kill -SIGTERM
So 'kill -SIGTERM 3026' would kill a broker process with PID 3026.
Cheers, Robert
On Mon, Jun 2, 2014 at 11:04 PM, rafeeq s <rafeeq.ec...@gmail.com> wrote:
> 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.
> > >
> >
>
