Kafka Upgrade 0.10.2.0 to 0.10.2.1 partitionRecordsOrFail

[Michael Rauter]

I try to do a rolling upgrade a kafka cluster from 0.10.2.0 to 0.10.2.1.

But after upgrade the first node to 0.10.2.1 I get:

[2017-05-19 16:02:03,941] ERROR [KafkaApi-3] Error when handling request 
{acks=-1,timeout=30000,topic_data=[{topic=topic 
data=[{partition=4,record_set=[(offset=0,record=Record(magic = 1, attributes = 
0, compression = NONE, crc = 3249288337, CreateTime = 1495202502242, key = 32 
bytes, value = 80 bytes))]}]}]} (kafka.server.KafkaApis)
java.lang.NoSuchMethodError: 
org.apache.kafka.common.requests.ProduceRequest.partitionRecordsOrFail()Ljava/util/Map;
            at kafka.server.KafkaApis.handleProducerRequest(KafkaApis.scala:353)
            at kafka.server.KafkaApis.handle(KafkaApis.scala:80)
            at 
kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:62)
            at java.lang.Thread.run(Thread.java:745)

Downgrade to 0.10.2.0 and everything is running again.

my steps:

stop kafka
upgrade package
start kafka

0.10.2.0 is the initial setup of the cluster