git.net

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

getting Timeout expired while fetching topic metadata


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