Re: Producer Configuration

2021-03-04 Thread Dawid Wysakowicz
es (in my case it is empty as well, but Kafka works). Check logs. > > > *From:* Claude M > *Sent:* Saturday, February 27, 2021 4:00:23 PM > *To:* Alexey Trenikhun > *Cc:* user > *Subject:* Re: Producer Conf

Re: Producer Configuration

2021-02-27 Thread Alexey Trenikhun
, 2021 4:00:23 PM To: Alexey Trenikhun Cc: user Subject: Re: Producer Configuration 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

Re: Producer Configuration

2021-02-27 Thread Claude M
: > Can you produce messages using Kafka console producer connect using same > properties ? > > -- > *From:* Claude M > *Sent:* Saturday, February 27, 2021 8:05 AM > *To:* Alexey Trenikhun > *Cc:* user > *Subject:* Re: Producer Configuration >

Re: Producer Configuration

2021-02-27 Thread Alexey Trenikhun
Can you produce messages using Kafka console producer connect using same properties ? From: Claude M Sent: Saturday, February 27, 2021 8:05 AM To: Alexey Trenikhun Cc: user Subject: Re: Producer Configuration Thanks for your reply, yes it was specified

Re: Producer Configuration

2021-02-27 Thread Claude M
s like > you didn’t set it > > -- > *From:* Claude M > *Sent:* Friday, February 26, 2021 12:02:10 PM > *To:* user > *Subject:* Producer Configuration > > Hello, > > I created a simple Producer and when the

Re: Producer Configuration

2021-02-26 Thread Alexey Trenikhun
I believe bootstrap.servers is mandatory Kafka property, but it looks like you didn’t set it From: Claude M Sent: Friday, February 26, 2021 12:02:10 PM To: user Subject: Producer Configuration Hello, I created a simple Producer and when the job ran

Producer Configuration

2021-02-26 Thread Claude M
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();