public KafkaProperties()

in src/main/java/com/googlesource/gerrit/plugins/kafka/config/KafkaProperties.java [48:58]

• 11 lines of code
• 1 McCabe index (conditional complexity)

  public KafkaProperties(PluginConfigFactory configFactory, @PluginName String pluginName) {
    super();
    setDefaults();
    PluginConfig fromGerritConfig = configFactory.getFromGerritConfig(pluginName);
    topic = fromGerritConfig.getString(STREAM_EVENTS_TOPIC_FIELD, STREAM_EVENTS_TOPIC_DEFAULT);
    sendAsync = fromGerritConfig.getBoolean(SEND_ASYNC_FIELD, SEND_ASYNC_DEFAULT);
    sendStreamEvents =
        fromGerritConfig.getBoolean(SEND_STREAM_EVENTS_FIELD, SEND_STREAM_EVENTS_DEFAULT);
    applyConfig(fromGerritConfig);
    initDockerizedKafkaServer();
  }