public void close()

in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java [950:973]

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

    public void close() throws Exception {
        cancel();

        joinDiscoveryLoopThread();

        Exception exception = null;
        if (partitionDiscoverer != null) {
            try {
                partitionDiscoverer.close();
            } catch (Exception e) {
                exception = e;
            }
        }

        try {
            super.close();
        } catch (Exception e) {
            exception = ExceptionUtils.firstOrSuppressed(e, exception);
        }

        if (exception != null) {
            throw exception;
        }
    }