in src/main/java/com/googlesource/gerrit/plugins/kafka/api/KafkaApiModule.java [49:53]
public void setPreviousBrokerApi(DynamicItem<BrokerApi> previousBrokerApi) {
if (previousBrokerApi != null && previousBrokerApi.get() != null) {
this.activeConsumers = previousBrokerApi.get().topicSubscribers();
}
}