@Override
    int numBuffered() {
        return totalBuffered;
    }
@throws IllegalStateException if the record's partition does not belong to this partition group
streams/src/main/java/org/apache/kafka/streams/processor/internals/PartitionGroup.java