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.
