Eyal Pe'er mailto:eyal.p...@startapp.com>>
Cc: user mailto:user@flink.apache.org>>
Subject: Re: timeout error while connecting to Kafka
I'm trying to understand.
Did you submitted your jar throw the flink web UI ,
And then you got the time out error ?
On Sun, Aug 25, 2019
A935BE30]
From: miki haiat mailto:miko5...@gmail.com>>
Sent: Sunday, August 25, 2019 3:50 PM
To: Eyal Pe'er mailto:eyal.p...@startapp.com>>
Cc: user@flink.apache.org<mailto:user@flink.apache.org>
Subject: Re: timeout error while connecting to Kafka
Did you try to submit it to
t; *From:* miki haiat
> *Sent:* Sunday, August 25, 2019 3:50 PM
> *To:* Eyal Pe'er
> *Cc:* user@flink.apache.org
> *Subject:* Re: timeout error while connecting to Kafka
>
>
>
> Did you try to submit it to remote cluster ?
>
>
>
>
>
Eyal Peer / Data Platform Developer
[cid:image001.png@01D55B5F.A935BE30]
From: miki haiat
Sent: Sunday, August 25, 2019 3:50 PM
To: Eyal Pe'er
Cc: user@flink.apache.org
Subject: Re: timeout error while connecting to Kafka
Did you try to submit it to remote cluster ?
On Sun, Aug 25, 2019
t;
> Eyal Peer */ *Data Platform Developer
>
>
>
> *From:* Eyal Pe'er
> *Sent:* Sunday, August 25, 2019 2:20 PM
> *To:* miki haiat
> *Cc:* user@flink.apache.org
> *Subject:* RE: timeout error while connecting to Kafka
>
>
>
> Hi,
>
> I removed that
r
Cc: miki haiat ; user@flink.apache.org
Subject: Re: timeout error while connecting to Kafka
What is the topic replication factor? how many kafka brokers do you have?
I were facing the same exception when one of my brokers was down and the topic
had no replica (replication_factor=1)
On Sun, A
eeper.connect").
>
> I saw that in Apache Flink-Kafka connector zookeeper.connect only
> required for Kafka 0.8, but maybe I still need to use it ?
>
> Best regards
>
> Eyal Peer */ *Data Platform Developer
>
>
>
> *From:* miki haiat
> *Sent:* Thursday, Au
PM
To: miki haiat
Cc: user@flink.apache.org
Subject: RE: timeout error while connecting to Kafka
Hi,
I removed that dependency, but it still fails.
The reason why I used Kafka 1.5.0 is because I followed a training which used
it (https://www.baeldung.com/kafka-flink-data-pipeline).
If needed,
a Platform Developer
[cid:image001.png@01D55B4F.C03EE8F0]
From: miki haiat
Sent: Thursday, August 22, 2019 2:29 PM
To: Eyal Pe'er
Cc: user@flink.apache.org
Subject: Re: timeout error while connecting to Kafka
Can you try to remove this from your pom file .
org.apache.flink
>
>
>
> org.apache.flink
>
> flink-clients_2.10
>
> 1.1.4
>
>
>
>
>
> org.apache.flink
>
> flink-connector-kafka_2.11
>
> 1.7.0
>
>
>
.png@01D558F0.E155F580]
From: miki haiat
Sent: Thursday, August 22, 2019 11:03 AM
To: Eyal Pe'er
Cc: user@flink.apache.org
Subject: Re: timeout error while connecting to Kafka
Can you double check that the kafka instance is up ?
The code looks fine.
Best,
Miki
On Thu, Aug 22, 2019 at 10:
The code itself is fine. Turning the app’s log level to DEBUG will give you
more information.
BTW, please make sure that the addresses of Kafka brokers are properly resolved.
> On Aug 22, 2019, at 15:45, Eyal Pe'er wrote:
>
> Hi,
>
> I'm trying to consume events using Apache Flink.
>
> The
Can you double check that the kafka instance is up ?
The code looks fine.
Best,
Miki
On Thu, Aug 22, 2019 at 10:45 AM Eyal Pe'er wrote:
> Hi,
>
> I'm trying to consume events using Apache Flink.
>
> The code is very basic, trying to connect the topic split words by space
> and print it to the
13 matches
Mail list logo
