Description
class FirebaseSubscriptionErrorEvent(BaseKafkaModel):
_topic = 'firebase_subscription_errors'
def __init__(self, uuid: str, code: int, subscriber_id: int, timestamp: int = None, **kwargs):
super().__init__(**kwargs)
self.uuid = uuid
self.code = code
self.subscriber_id = subscriber_id
self.timestamp = timestamp or int(time.time())