Re: 0.8.2.1 Client not able to connect with Kafka 0.10.0.1 cluster even the cluster has message format version 0.8.2.

Hi, After checking we found that there was an issue with version id passed in ConsumerMetadataRequest after setting it to 0(ConsumerMetadataRequest.currentVersion()). It started working! Thanks! Madhukar On Tue, Nov 1, 2016 at 10:29 PM, Madhukar Bharti wrote: > Hi

Re: 0.8.2.1 Client not able to connect with Kafka 0.10.0.1 cluster even the cluster has message format version 0.8.2.

Hi Ismael, Below is the stack trace from client. java.io.EOFException: Received -1 when reading from channel, socket has >> likely been closed. > > at kafka.utils.Utils$.read(Utils.scala:381) > > at >> kafka.network.BoundedByteBufferReceive.readFrom(BoundedByteBufferReceive.scala:54) > > at

Re: 0.8.2.1 Client not able to connect with Kafka 0.10.0.1 cluster even the cluster has message format version 0.8.2.

OffsetFetchRequest should have api key = 9, but for some reason your broker is receiving a request with api key = 10 (GroupCoordinatorRequest). Can you provide the stacktrace from the client as well? Ismael On Tue, Nov 1, 2016 at 12:13 PM, Madhukar Bharti wrote: > Hi,

0.8.2.1 Client not able to connect with Kafka 0.10.0.1 cluster even the cluster has message format version 0.8.2.

Hi, We have upgraded our cluster from 0.8.2.1 to 0.10.0.1. Now *log.message.format.version* is set to *0.8.2. * We are still using Kafka 0.8.2.1 jars in client side, when we tried to fetch consumer offset using BlockingChannel and OffsetFetchRequest as in example here