public static void readZkProps()

in crossdc-commons/src/main/java/org/apache/solr/crossdc/common/KafkaCrossDcConf.java [280:294]

• 15 lines of code
• 5 McCabe index (conditional complexity)

  public static void readZkProps(Map<String,Object> properties, Properties zkProps) {
    Map<Object, Object> zkPropsUnprocessed = new HashMap<>(zkProps);
    for (ConfigProperty configKey : KafkaCrossDcConf.CONFIG_PROPERTIES) {
      if (properties.get(configKey.getKey()) == null || ((String)properties.get(configKey.getKey())).isBlank()) {
        properties.put(configKey.getKey(), (String) zkProps.getProperty(
            configKey.getKey()));
        zkPropsUnprocessed.remove(configKey.getKey());
      }
    }
    zkPropsUnprocessed.forEach((key, val) -> {
      if (properties.get(key) == null) {
        properties.put((String) key, (String) val);
      }
    });
  }