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
