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 <bhartimadhu...@gmail.com> wrote: > 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 > <https://cwiki.apache.org/confluence/display/KAFKA/ > Committing+and+fetching+consumer+offsets+in+Kafka>, > we are getting below exceptions in brokers. > > ERROR Closing socket for 172.19.8.200:9092-192.168.1.1:43682 because of > > error (kafka.network.Processor) > > kafka.network.InvalidRequestException: Error getting request for apiKey: > > 10 and apiVersion: 1 > > at > > kafka.network.RequestChannel$Request.liftedTree2$1( > RequestChannel.scala:95) > > at > > kafka.network.RequestChannel$Request.<init>(RequestChannel.scala:87) > > at > > kafka.network.Processor$$anonfun$processCompletedReceives$1. > apply(SocketServer.scala:488) > > at > > kafka.network.Processor$$anonfun$processCompletedReceives$1. > apply(SocketServer.scala:483) > > at scala.collection.Iterator$class.foreach(Iterator.scala:893) > > at scala.collection.AbstractIterator.foreach( > Iterator.scala:1336) > > at > > scala.collection.IterableLike$class.foreach(IterableLike.scala:72) > > at scala.collection.AbstractIterable.foreach(Iterable.scala:54) > > at > > kafka.network.Processor.processCompletedReceives(SocketServer.scala:483) > > at kafka.network.Processor.run(SocketServer.scala:413) > > at java.lang.Thread.run(Thread.java:745) > > Caused by: java.lang.IllegalArgumentException: Invalid version for API > key > > 10: 1 > > at > > org.apache.kafka.common.protocol.ProtoUtils.schemaFor( > ProtoUtils.java:31) > > at > > org.apache.kafka.common.protocol.ProtoUtils. > requestSchema(ProtoUtils.java:44) > > at > > org.apache.kafka.common.protocol.ProtoUtils. > parseRequest(ProtoUtils.java:60) > > at > > org.apache.kafka.common.requests.GroupCoordinatorRequest.parse( > GroupCoordinatorRequest.java:59) > > at > > org.apache.kafka.common.requests.AbstractRequest. > getRequest(AbstractRequest.java:54) > > at > > kafka.network.RequestChannel$Request.liftedTree2$1( > RequestChannel.scala:92) > > ... 10 more > > > > But, the same code is working fine with Kafka 0.8.2.1 cluster. > I am aware of some protocol changes has been made in Kafka-0.10.X.X but > don't want to update our client to 0.10.0.1 as of now. Is there any way > without updating client the same code will still give the consumer offset. > > > > > -- > Thanks and Regards, > Madhukar Bharti > Mob: 7845755539 >
