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));
}
}