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
at
> *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/kaf
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
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 console. Kafka version is 0.9.
import org.apache.flink.api.common.functions.FlatMapFunction;
import org.apache.flink.api.common.serialization.SimpleStri
14 matches
Mail list logo
