void writeRecord()

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

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

    void writeRecord(SinkRecord sinkRecord) throws ConnectException {
        if (sinkRecord != null) {
            try (AutoCloseableLock ignored = new AutoCloseableLock(reentrantReadWriteLock.readLock())) {
                this.currentOffset = sinkRecord.kafkaOffset();
                fileWriter.writeData(sinkRecord);
            } catch (IOException | DataException ex) {
                handleErrors(sinkRecord, ex);
            }
        }
    }