Description

Whenever any of quota related information is changed for a particular user (e.g. subscribers limit), this event is emitted so other services can react accordingly.

class QuotaEvent(BaseKafkaModel):
    _topic = 'quota_events'
 
    def __init__(self, external_user_id: int, subscribers_limit: int = None, **kwargs):
        super(QuotaEvent, self).__init__(**kwargs)
        self.external_user_id = external_user_id or 0
        self.subscribers_limit = subscribers_limit or 0