Yes, the flink job also works in producing messages. It's just that after
a short period of time, it fails w/ a timeout. That is why I'm trying to
set a longer timeout period but it doesn't seem like the properties are
being picked up.
On Sat, Feb 27, 2021 at 1:17 PM Alexey Trenikhun <yen...@msn.com> wrote:
> Can you produce messages using Kafka console producer connect using same
> properties ?
>
> ------------------------------
> *From:* Claude M <claudemur...@gmail.com>
> *Sent:* Saturday, February 27, 2021 8:05 AM
> *To:* Alexey Trenikhun <yen...@msn.com>
> *Cc:* user <user@flink.apache.org>
> *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 <yen...@msn.com> wrote:
>
> I believe bootstrap.servers is mandatory Kafka property, but it looks like
> you didn’t set it
>
> ------------------------------
> *From:* Claude M <claudemur...@gmail.com>
> *Sent:* Friday, February 26, 2021 12:02:10 PM
> *To:* user <user@flink.apache.org>
> *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.
>
>
