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

Reply via email to