protected void doStop()

in flume-kafka-source/src/main/java/org/apache/flume/source/kafka/KafkaSource.java [489:498]

• 10 lines of code
• 3 McCabe index (conditional complexity)

  protected void doStop() throws FlumeException {
    if (consumer != null) {
      consumer.wakeup();
      consumer.close();
    }
    if (counter != null) {
      counter.stop();
    }
    log.info("Kafka Source {} stopped. Metrics: {}", getName(), counter);
  }