Re: Producer Configuration

Posted by Claude Murad on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Producer-Configuration-tp41757p41769.html

Thanks for your reply, yes it was specified.  Sorry I forgot to include it:

 properties.setProperty("bootstrap.servers", "localhost:9092");

On Fri, Feb 26, 2021 at 7:56 PM Alexey Trenikhun <[hidden email]> wrote:

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.