public void disconnect()

in src/main/java/com/googlesource/gerrit/plugins/kafka/api/KafkaBrokerApi.java [59:64]

• 6 lines of code
• 2 McCabe index (conditional complexity)

  public void disconnect() {
    for (KafkaEventSubscriber subscriber : subscribers) {
      subscriber.shutdown();
    }
    subscribers.clear();
  }