public TopicPartition partition() {
        return partition;
    }
Returns the partition with which this queue is associated

@return TopicPartition
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordQueue.java