in src/main/java/com/google/cloud/run/kafkascaler/ConfigurationProvider.java [107:118]
private ImmutableSet<String> getMissingEnvVars(Set<String> requiredEnvVars) {
Set<String> missingEnvVars = new HashSet<>();
for (String requiredEnvVar : requiredEnvVars) {
String value = envProvider.getEnv(requiredEnvVar);
if (isNullOrEmpty(value)) {
missingEnvVars.add(requiredEnvVar);
}
}
return ImmutableSet.copyOf(missingEnvVars);
}