public void close()

in pulsar-client-kafka-compat/pulsar-client-kafka_0_8/src/main/java/org/apache/kafka/clients/simple/consumer/PulsarKafkaSimpleConsumer.java [271:299]

• 26 lines of code
• 7 McCabe index (conditional complexity)

    public void close() {

        if (topicConsumerMap != null) {
            topicConsumerMap.forEach((topic, consumer) -> {
                try {
                    consumer.close();
                } catch (PulsarClientException e) {
                    log.warn("Failed to close consumer for topic {}", topic, e);
                }
            });
            topicConsumerMap.clear();
        }

        if (client != null) {
            try {
                client.close();
            } catch (PulsarClientException e) {
                log.warn("Failed to close pulsar-client ", e);
            }
        }

        if (admin != null) {
            try {
                admin.close();
            } catch (Exception e) {
                log.warn("Failed to close pulsar-admin ", e);
            }
        }
    }