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