synchronized void resetGroupSubscription() {
        groupSubscription = Collections.emptySet();
    }
Reset the group's subscription to only contain topics subscribed by this consumer.
clients/src/main/java/org/apache/kafka/clients/consumer/internals/SubscriptionState.java