public void shutdown()

in pulsar-client-kafka-compat/pulsar-client-kafka_0_8/src/main/java/org/apache/kafka/clients/consumer/ConsumerConnector.java [188:206]

• 19 lines of code
• 5 McCabe index (conditional complexity)

    public void shutdown() {
        if (executor != null) {
            executor.shutdown();
        }
        if (topicStreams != null) {
            topicStreams.forEach(stream -> {
                try {
                    stream.close();
                } catch (Exception e) {
                    log.warn("Failed to close stream {}, {}", stream, e.getMessage());
                }
            });
        }
        try {
            client.close();
        } catch (PulsarClientException e) {
            log.warn("Failed to close client {}", e.getMessage());
        }
    }