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

Hi Jayant, Can you try to connect to kafka server 0.10.x via flink-connector-kafka-0.10? See if it still throws this exception. Thanks, vino. Jayant Ameta 于2018年9月4日周二 下午1:20写道： > Flink: 1.4.2 > flink-connector-kafka-0.11_2.11 (1.4.2) > Kafka: 0.10.1.0 > > Jayant Ameta > > > On Tue, Sep 4, 201

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

Flink: 1.4.2 flink-connector-kafka-0.11_2.11 (1.4.2) Kafka: 0.10.1.0 Jayant Ameta On Tue, Sep 4, 2018 at 10:16 AM vino yang wrote: > Hi Jayant, > > Can you provide more specific information? For example, the version of > your Flink, the version of kafka on which Flink-Kafka-Connector depends,

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

Hi Jayant, Can you provide more specific information? For example, the version of your Flink, the version of kafka on which Flink-Kafka-Connector depends, and the version of kafka server. Thanks, vino. Jayant Ameta 于2018年9月4日周二 下午12:32写道： > I am getting the same error. Is there a way to retry/

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

I am getting the same error. Is there a way to retry/ignore instead of killing the job? Jayant Ameta On Tue, May 22, 2018 at 7:58 PM gerardg wrote: > 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,

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. Gerard -- Sent from: http://apache-flink-user-mailing-list-arc

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

thank you Piotr On Mon, May 7, 2018 at 2:59 PM Piotr Nowojski wrote: > Hi, > > Regardless if that will fix the problem or not, please consider upgrading > to Kafka 0.11.0.2 or 1.0.1. Kafka 0.11.0 release was quite messy and it > might be that the bug you have hit was fixed in 0.11.0.2. > > As a

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

Hi, Regardless if that will fix the problem or not, please consider upgrading to Kafka 0.11.0.2 or 1.0.1. Kafka 0.11.0 release was quite messy and it might be that the bug you have hit was fixed in 0.11.0.2. As a side note, as far as we know our FlinkKafkaProducer011 works fine with Kafka 1.0.

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

Hi Piotr, using 0.11.0 Kafka version On Sat, May 5, 2018 at 10:19 AM Piotr Nowojski wrote: > FlinkKafka011Producer uses Kafka 0.11.0.2. > > However I’m not sure if bumping KafkaProducer version solves this issue or > upgrading Kafka. What Kafka version are you using? > > Piotrek > > > On 4 May 2

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

FlinkKafka011Producer uses Kafka 0.11.0.2. However I’m not sure if bumping KafkaProducer version solves this issue or upgrading Kafka. What Kafka version are you using? Piotrek > On 4 May 2018, at 17:55, Alexander Smirnov > wrote: > > Thanks for quick turnaround Stefan, Piotr > > This is a

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

Thanks for quick turnaround Stefan, Piotr This is a rare reproducible issue and I will keep an eye on it searching on the Stack Overflow I found https://stackoverflow.com/questions/43378664/kafka-leader-election-causes-kafka-streams-crash They say that the problem is fixed in 0.10.2.1 of kafka p

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

Hi, I think Stefan is right. Quick google search points to this: https://stackoverflow.com/questions/47767169/kafka-this-server-is-not-the-leader-for-that-topic-partition Please let us k

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

Hi, I think in general this means that your producer client does not connect to the correct Broker (the leader) but to a broker that is just a follower and the follower can not execute that request. However, I am not sure what causes this in the context of the FlinkKafkaProducer. Maybe Piotr (i