def subscription(self):
        """Get the current topic subscription.

        Returns:
            set: {topic, ...}
        """
        if self._subscription.subscription is None:
            return None
        return self._subscription.subscription.copy()
Get the current topic subscription.

        Returns:
            set: {topic, ...}
        
kafka/consumer/group.py