public static void checkKeyExists()

in src/main/java/com/google/cloud/run/kafkascaler/scalingconfig/Validation.java [34:39]


  public static void checkKeyExists(Map<String, Object> input, String key, String resourcePath) {
    if (!input.containsKey(key)) {
      throw new IllegalArgumentException(
          String.format("Failed to parse scaling config: %s.%s is required", resourcePath, key));
    }
  }