Thanks for pointing this out. There was a broker instance of version 0.10.1.0 running.
On May 23, 2017 11:34 AM, "Ewen Cheslack-Postava" <e...@confluent.io> wrote: > Version 2 of UpdateMetadataRequest does not exist in version 0.9.0.1. This > suggests that you have a broker with a newer version of Kafka running > against the same ZK broker. Do you have any other versions running? Or is > it possible this is a shared ZK cluster and you're not using a namespace > within ZK for each cluster? > > -Ewen > > On Mon, May 22, 2017 at 12:33 AM, dhiraj prajapati <dhirajp...@gmail.com> > wrote: > > > Hi, > > I am getting the below exception while starting kafka broker 0.9.0.1: > > > > kafka.common.KafkaException: Version 2 is invalid for > > UpdateMetadataRequest. Valid versions are 0 or 1. > > at > > kafka.api.UpdateMetadataRequest$.readFrom(UpdateMetadataRequest.scala: > 58) > > at kafka.api.RequestKeys$$anonfun$7.apply(RequestKeys.scala:54) > > at kafka.api.RequestKeys$$anonfun$7.apply(RequestKeys.scala:54) > > at kafka.network.RequestChannel$Request.<init>(RequestChannel. > > scala:66) > > at kafka.network.Processor$$anonfun$run$11.apply( > > SocketServer.scala:426) > > at kafka.network.Processor$$anonfun$run$11.apply( > > SocketServer.scala:421) > > at scala.collection.Iterator$class.foreach(Iterator.scala:742) > > at scala.collection.AbstractIterator.foreach(Iterator.scala:1194) > > at scala.collection.IterableLike$class.foreach(IterableLike. > scala:72) > > at scala.collection.AbstractIterable.foreach(Iterable.scala:54) > > at kafka.network.Processor.run(SocketServer.scala:421) > > at java.lang.Thread.run(Thread.java:745) > > > > What could be the issue? > > > > Regards, > > Dhiraj > > >