public void flush()

in timebase-kafka-connector/src/main/java/deltix/kafka/connect/TBSinkTask.java [165:179]

• 15 lines of code
• 4 McCabe index (conditional complexity)

    public void flush(Map<TopicPartition, OffsetAndMetadata> currentOffsets) {
        try {
            if (LOG.isDebugEnabled()) {
                StringBuilder offsetInfo = new StringBuilder("Flushing at ");
                currentOffsets.forEach((key, value) -> offsetInfo.append(key).append(":").append(value));
                LOG.debug(offsetInfo.toString());
            }
           if (tbLoader != null)
               tbLoader.flush();
        }
        catch (IOException ex) {
            LOG.error("Failed to write to TimeBase", ex);
            throw new RuntimeException("Failed to write to TimeBase", ex);
        }
    }