@Override
        public boolean isPartitionAllowed(int partition) {
            return partition == this.partition;
        }
Used to filter partitions based on a certain criteria, for example, a set of partition ids.
server-common/src/main/java/org/apache/kafka/server/util/PartitionFilter.java