in crossdc-producer/src/main/java/org/apache/solr/update/processor/MirroringUpdateRequestProcessorFactory.java [77:91]
public void init(final NamedList args) {
super.init(args);
Boolean enabled = args.getBooleanArg("enabled");
if (enabled != null && !enabled) {
this.enabled = false;
}
for (ConfigProperty configKey : KafkaCrossDcConf.CONFIG_PROPERTIES) {
String val = args._getStr(configKey.getKey(), null);
if (val != null && !val.isBlank()) {
properties.put(configKey.getKey(), val);
}
}
}