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