public void close()

in org.apache.aries.events.kafka/src/main/java/org/apache/aries/events/kafka/KafkaSubscription.java [75:78]

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

    public void close() {
        running = false;
        consumer.wakeup();
    }