public void subscribe()

in src/main/java/com/googlesource/gerrit/plugins/kafka/subscribe/KafkaEventSubscriber.java [74:80]

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

  public void subscribe(String topic, java.util.function.Consumer<EventMessage> messageProcessor) {
    this.topic = topic;
    this.messageProcessor = messageProcessor;
    logger.atInfo().log(
        "Kafka consumer subscribing to topic alias [%s] for event topic [%s]", topic, topic);
    runReceiver();
  }