public void stop()

in src/main/java/com/microsoft/azure/kusto/kafka/connect/sink/KustoSinkTask.java [441:458]

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

    public void stop() {
        log.warn("Stopping KustoSinkTask");
        // First stop so that no more ingestions trigger from timer flushes
        for (TopicPartitionWriter writer : writers.values()) {
            writer.stop();
        }

        for (TopicPartitionWriter writer : writers.values()) {
            writer.close();
        }
        try {
            if (kustoIngestClient != null) {
                kustoIngestClient.close();
            }
        } catch (IOException e) {
            log.error("Error closing kusto client", e);
        }
    }