subscriber-update

Description

Any subscribers update will produce this event.

class SubscriberUpdateEvent(BaseKafkaModel):
    _topic = 'subscriber_update_event'
 
    def __init__(self, channel_id: int, subscriber_id: int, data_json: str = None, timestamp: int = None, **kwargs):
        super(SubscriberUpdateEvent, self).__init__(**kwargs)
        self.channel_id = channel_id
        self.subscriber_id = subscriber_id
        self.data_json = data_json
        self.timestamp = timestamp or int(time.time())