in src/main/java/com/google/cloud/run/kafkascaler/ConfigurationProvider.java [164:171]
Properties kafkaClientProperties(String kafkaClientPropertiesFile) throws IOException {
try (InputStream inputStream = new FileInputStream(kafkaClientPropertiesFile)) {
return kafkaClientProperties(inputStream);
} catch (IOException e) {
logger.atSevere().log("Unable to load client properties file %s ", kafkaClientPropertiesFile);
throw e;
}
}