long partitionTime() {
        return partitionTime;
    }
@return the local partitionTime for this particular RecordQueue
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordQueue.java