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