docs: def unsubscribe(self):
          """Clear all topic subscriptions and partition assignments"""
          self.subscription = None
          self._user_assignment.clear()
          self.assignment.clear()
          self.subscribed_pattern = None