public KafkaSubscriberProperties()

in src/main/java/com/googlesource/gerrit/plugins/kafka/config/KafkaSubscriberProperties.java [34:43]


  public KafkaSubscriberProperties(
      PluginConfigFactory configFactory, @PluginName String pluginName) {
    super(configFactory, pluginName);

    this.pollingInterval =
        Integer.parseInt(getProperty("polling.interval.ms", DEFAULT_POLLING_INTERVAL_MS));
    this.groupId = getProperty("group.id");
    this.numberOfSubscribers =
        Integer.parseInt(getProperty("number.of.subscribers", DEFAULT_NUMBER_OF_SUBSCRIBERS));
  }