private void handleErrors()

in src/main/java/com/microsoft/azure/kusto/kafka/connect/sink/TopicPartitionWriter.java [227:237]

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

    private void handleErrors(SinkRecord sinkRecord, Exception ex) {
        if (BehaviorOnError.FAIL == behaviorOnError) {
            throw new ConnectException(FILE_EXCEPTION_MESSAGE, ex);
        } else if (BehaviorOnError.LOG == behaviorOnError) {
            log.error(FILE_EXCEPTION_MESSAGE, ex);
            sendFailedRecordToDlq(sinkRecord);
        } else {
            log.debug(FILE_EXCEPTION_MESSAGE, ex);
            sendFailedRecordToDlq(sinkRecord);
        }
    }