Producer Configuration

Posted by Claude Murad on Feb 26, 2021; 8:02pm
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Producer-Configuration-tp41757.html

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.