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 <avi.l...@bluevoyant.com> 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 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 consumerProperties: Properties = {
> val p = new Properties()
> p.setProperty("bootstrap.servers", kafkaBootStrapServers)
> p.setProperty("group.id", groupId)
> p.setProperty("client.id", s"queue-consumer-${randomUUID().toString}")
>
> p.setProperty("ssl.keystore.location","/usr/path_to/kafka_ssl_client.keystore.jks"))
> p.setProperty("ssl.keystore.password", "some password")
> p.setProperty("ssl.truststore.location",
> "/usr/path_to/kafka_ssl_client.keystore.jks")
> p.setProperty("ssl.truststore.password", "some password")
> p
> }
>
> please advise
>
> Thanks
> Avi
>
