We are running some tests on upgrading from Kafka 2.10-0.8.2.1 to 2.11-0.10.00. So far, we only upgraded the server. All of the clients that I could verify are still using the Maven kafka-clients version 0.8.2.1. There are a number of exceptions in the server.log:
[2016-06-07 16:00:00,266] ERROR Closing socket for 172.20.8.19:9092-172.20.3.0:53901 because of error (kafka.network.Processor) kafka.network.InvalidRequestException: Error getting request for apiKey: 2 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:785) Caused by: java.lang.IllegalArgumentException: Invalid version for API key 2: 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.ListOffsetRequest.parse(ListOffsetRequest.java:142) at org.apache.kafka.common.requests.AbstractRequest.getRequest(AbstractRequest.java:46) at kafka.network.RequestChannel$Request.liftedTree2$1(RequestChannel.scala:92) ... 10 more Any guidance on what the source of this might be? Chris