public void clear() {
        fifoQueue.clear();
        headRecord = null;
        headRecordSizeInBytes = 0L;
        partitionTime = UNKNOWN;
    }
Clear the fifo queue of its elements
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordQueue.java