public void inform()

in crossdc-producer/src/main/java/org/apache/solr/update/processor/MirroringUpdateRequestProcessorFactory.java [163:195]

• 22 lines of code
• 4 McCabe index (conditional complexity)

    public void inform(SolrCore core) {
        log.info("KafkaRequestMirroringHandler inform enabled={}", this.enabled);

        if (core.getCoreContainer().isZooKeeperAware()) {
            lookupPropertyOverridesInZk(core);
        } else {
            applyArgsOverrides();
            if (enabled) {
                throw new SolrException(SolrException.ErrorCode.SERVER_ERROR, getClass().getSimpleName() + " only supported in SolrCloud mode; please disable or remove from solrconfig.xml");
            }
            log.warn("Core '{}' was configured to use a disabled {}, but {} is only supported in SolrCloud deployments.  A NoOp processor will be used instead", core.getName(), this.getClass().getSimpleName(), this.getClass().getSimpleName());
        }

        if (!enabled) {
            return;
        }

        ConfUtil.verifyProperties(properties);

        // load the request mirroring sink class and instantiate.
       // mirroringHandler = core.getResourceLoader().newInstance(RequestMirroringHandler.class.getName(), KafkaRequestMirroringHandler.class);

        conf = new KafkaCrossDcConf(properties);


        KafkaMirroringSink sink = new KafkaMirroringSink(conf);

        Closer closer = new Closer(sink);
        core.addCloseHook(new MyCloseHook(closer));

        producerMetrics = new ProducerMetrics(core.getSolrMetricsContext().getChildContext(this), core);
        mirroringHandler = new KafkaRequestMirroringHandler(sink);
    }