public void stop()

in pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/PulsarOffsetBackingStore.java [163:185]

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

    public void stop() {
        if (null != producer) {
            try {
                producer.close();
            } catch (PulsarClientException e) {
                log.warn("Failed to close producer", e);
            }
        }
        if (null != reader) {
            try {
                reader.close();
            } catch (IOException e) {
                log.warn("Failed to close reader", e);
            }
        }
        if (null != client) {
            try {
                client.close();
            } catch (IOException e) {
                log.warn("Failed to close client", e);
            }
        }
    }