@Override
    public void flush(Map<TopicPartition, OffsetAndMetadata> offsets) {
        log.trace("Flushing output stream for {}", logFilename());
        outputStream.flush();
    }
FileStreamSinkTask writes records to stdout or a file.
connect/file/src/main/java/org/apache/kafka/connect/file/FileStreamSinkTask.java