Your classpath seems to contain more than one version of the kafka-clients
jars (probably 0.10.2.0 and 0.10.2.1). partitionRecordsOrFail was added in
0.10.2.1 and the class from the older jar was loaded instead. Can you give
a little more details regarding the Kafka package you are using and how you
upgraded it?
Ismael
On Fri, May 19, 2017 at 3:54 PM, 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
>
