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
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,
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/
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,
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
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 contex
nfig.SESSION_TIMEOUT_MS_CONFIG, 2);
>>
>>
>>
>> On Fri, May 4, 2018 at 4:58 PM Piotr Nowojski > <mailto:pi...@data-artisans.com>> wrote:
>> Hi,
>>
>> I think Stefan is right. Quick google search points to this:
>> https://s
tr Nowojski
> wrote:
>
>> 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 know if changing your configurat
owojski <mailto:pi...@data-artisans.com>> wrote:
> 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
>
> <https://stackoverflow.com/questio
2018 um 15:45 schrieb Alexander Smirnov <
> alexander.smirn...@gmail.com>:
>
> Hi,
>
> what could cause the following exception?
>
> org.apache.flink.streaming.connectors.kafka.FlinkKafka011Exception: Failed
> to send data to Kafka: This server is not the leade
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
<https://stackoverflow.com/questions/47767169/kafka-this-server-is-not-the-leader-for-that-topic-partition>
Please
(in CC) has an idea?
Best,
Stefan
> Am 04.05.2018 um 15:45 schrieb Alexander Smirnov
> :
>
> Hi,
>
> what could cause the following exception?
>
> org.apache.flink.streaming.connectors.kafka.FlinkKafka011Exception: Failed to
> send data to Kafka: This server is no
Hi,
what could cause the following exception?
org.apache.flink.streaming.connectors.kafka.FlinkKafka011Exception: Failed
to send data to Kafka: This server is not the leader for that
topic-partition.
at
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer011.checkErroneous
13 matches
Mail list logo
