[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Re: This server is not the leader for that topic-partition

I've seen the same error while upgrading Kafka. We are using
FlinkKafkaProducer011 and Kafka version 1.0.0. While upgrading to Kafka
1.1.0, each time a server was restarted, an already running Flink job failed
with the same message.


Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/