private boolean flushing() {
        return toFlush != null;
    }
Set an offset for a partition using Connect data values
@param partition the partition to store an offset for
@param offset the offset
connect/runtime/src/main/java/org/apache/kafka/connect/storage/OffsetStorageWriter.java