[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Re: getting Timeout expired while fetching topic metadata

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 <miko5054@xxxxxxxxx> wrote:
Hi Avi,
Can you try to add this properties 

 props.put(CommonClientConfigs.SECURITY_PROTOCOL_CONFIG, "SSL");

On Mon, Dec 24, 2018 at 8:19 PM Avi Levi <avi.levi@xxxxxxxxxxxxxx> 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("", groupId)
    p.setProperty("", s"queue-consumer-${randomUUID().toString}")
    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")

please advise