TopicPartition partition() {
            return queue.partition();
        }
Return the stream-time of this partition group defined as the largest timestamp seen across all partitions
streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractPartitionGroup.java