Thanks Miki,
we had a bug in the certs. however the property you suggested gave as
better logs so it really cleared things. THANKS !!!
On Mon, Dec 24, 2018 at 8:45 PM miki haiat wrote:
> Hi Avi,
> Can you try to add this properties
>
> props.put(CommonClientConfigs.SECURITY_PROTOCOL_CONFIG, "SS
Hi Avi,
Can you try to add this properties
props.put(CommonClientConfigs.SECURITY_PROTOCOL_CONFIG, "SSL");
Thanks,
Miki
On Mon, Dec 24, 2018 at 8:19 PM Avi Levi wrote:
> Hi all,
> very new to flink so my apology if it seems trivial.
> We deployed flink on gcloud
> I am trying to connect to ka
Hi all,
very new to flink so my apology if it seems trivial.
We deployed flink on gcloud
I am trying to connect to kafka but keep getting this error:
*org.apache.kafka.common.errors.TimeoutException: Timeout expired while
fetching topic metadata*
this how my properties look like
val consumerPropert
