You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@kafka.apache.org by dhiraj prajapati <dh...@gmail.com> on 2017/05/22 07:33:32 UTC

Kafka broker startup issue

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

Re: Kafka broker startup issue

Posted by dhiraj prajapati <dh...@gmail.com>.

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" <ew...@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 <dh...@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
> >
>

Re: Kafka broker startup issue

Posted by dhiraj prajapati <dh...@gmail.com>.

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" <ew...@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 <dh...@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
> >
>

Re: Kafka broker startup issue

Posted by Ewen Cheslack-Postava <ew...@confluent.io>.

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 <dh...@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
>

Re: Kafka broker startup issue

Posted by Ewen Cheslack-Postava <ew...@confluent.io>.

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 <dh...@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
>