Hi Michael,
Could you double check if your old jar has been cleaned up on the location
that the new jar is copied to? From the stack trace "partitionRecordsOrFail"
it seems the old jar is still loaded.
Guozhang
On Fri, May 19, 2017 at 7:54 AM, Michael Rauter <mrau...@anexia-it.com>
wrote:
> 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
>
--
-- Guozhang
