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));
}