private void markPendingRevocationToPauseFetching(Set<TopicPartition> partitionsToRevoke) {
        log.debug("Marking partitions pending for revocation: {}", partitionsToRevoke);
        subscriptions.markPendingRevocation(partitionsToRevoke);
    }
Mark partitions as 'pending revocation', to effectively stop fetching.
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareMembershipManager.java