subscriber-report

Description

class SubscribersReport(BaseKafkaModel):
    _topic = 'subscribers_report'
 
    def __init__(self, owner_email: str, total_subscribers: int, 
                 timestamp: int = None, **kwargs):
        super(SubscribersReport, self).__init__(**kwargs)
        self.owner_email = owner_email
        self.total_subscribers = total_subscribers
        self.timestamp = timestamp or int(time.time())

Links

• producers:
  • manager observer
• consumers:
  • SSO payments usage