Can you produce messages using Kafka console producer connect using same properties ?
________________________________ From: Claude M <[email protected]> Sent: Saturday, February 27, 2021 8:05 AM To: Alexey Trenikhun <[email protected]> Cc: user <[email protected]> Subject: Re: Producer Configuration 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 <[email protected]<mailto:[email protected]>> wrote: I believe bootstrap.servers is mandatory Kafka property, but it looks like you didn’t set it ________________________________ From: Claude M <[email protected]<mailto:[email protected]>> Sent: Friday, February 26, 2021 12:02:10 PM To: user <[email protected]<mailto:[email protected]>> 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<http://request.timeout.ms>. Thus, I added the following properties. Properties properties = new Properties(); properties.setProperty("request.timeout.ms<http://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.
