public MirroringConfigSetsHandler()

in crossdc-producer/src/main/java/org/apache/solr/handler/admin/MirroringConfigSetsHandler.java [56:77]

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

  public MirroringConfigSetsHandler(CoreContainer coreContainer, KafkaMirroringSink sink) {
    super(coreContainer);
    log.info("Using MirroringCollectionsHandler.");
    if (sink == null) {
      Map<String, Object> properties = new HashMap<>();
      try {
        SolrZkClient zkClient = null;
        if (coreContainer.getZkController() != null) {
          zkClient = coreContainer.getZkController().getZkClient();
        }
        ConfUtil.fillProperties(zkClient, properties);
        ConfUtil.verifyProperties(properties);
        KafkaCrossDcConf conf = new KafkaCrossDcConf(properties);
        this.sink = new KafkaMirroringSink(conf);
      } catch (Exception e) {
        log.error("Exception configuring Kafka sink - mirroring disabled!", e);
        this.sink = null;
      }
    } else {
      this.sink = sink;
    }
  }