Properties kafkaClientProperties()

in src/main/java/com/google/cloud/run/kafkascaler/ConfigurationProvider.java [173:189]

• 14 lines of code
• 2 McCabe index (conditional complexity)

  Properties kafkaClientProperties(InputStream inputStream) throws IOException {
    Properties config = new Properties();

    try (BufferedReader bufferedReader =
        new BufferedReader(new InputStreamReader(inputStream, UTF_8))) {
      config.load(bufferedReader);
    }

    if (isNullOrEmpty(config.getProperty(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG))) {
      throw new IllegalArgumentException(
          "Kafka client property "
              + AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG
              + " is required but not set in the Kafka client properties file.");
    }

    return config;
  }