public void disconnect()

in src/main/java/com/googlesource/gerrit/plugins/kafka/session/KafkaSession.java [80:87]

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

  public void disconnect() {
    LOGGER.info("Disconnecting...");
    if (producer != null) {
      LOGGER.info("Closing Producer {}...", producer);
      producer.close();
    }
    producer = null;
  }