private void handleErrors()

in src/main/java/com/microsoft/azure/kusto/kafka/connect/sink/FileWriter.java [195:203]

• 9 lines of code
• 3 McCabe index (conditional complexity)

    private void handleErrors(String message, Exception e) {
        if (KustoSinkConfig.BehaviorOnError.FAIL == behaviorOnError) {
            throw new ConnectException(message, e);
        } else if (KustoSinkConfig.BehaviorOnError.LOG == behaviorOnError) {
            log.error("{}", message, e);
        } else {
            log.debug("{}", message, e);
        }
    }