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 <miko5...@gmail.com> wrote:
> 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
>>
>
