Re: Producer Configuration

Posted by Alexey Trenikhun on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Producer-Configuration-tp41757p41759.html

I believe bootstrap.servers is mandatory Kafka property, but it looks like you didn’t set it

---

From: Claude M <[hidden email]>
Sent: Friday, February 26, 2021 12:02:10 PM
To: user <[hidden email]>
Subject: Producer Configuration

 

Hello,

 

I created a simple Producer and when the job ran, it was getting the following error: 

Caused by: org.apache.kafka.common.errors.TimeoutException

I read about increasing the request.timeout.ms.   Thus, I added the following properties.  

Properties properties = new Properties();
properties.setProperty("request.timeout.ms", "30000");
properties.setProperty("retries", "20");
DataStream<String> stream = env.addSource(new SimpleStringGenerator());
stream.addSink(new FlinkKafkaProducer<>("flink-test", new SimpleStringSchema(), properties));

However, after the job is submitted, the User Configuration is empty, please see attached.  

Therefore, it seems these properties are taking into effect since I still have the same problem.  

Any help on these issues are appreciated, thanks.