subscription-extended

Description

Happens on new subscribers becoming active. Contains additional data about subscriber’s subscription, like segment IDs it belongs to.

class SubscriptionEventExtended(BaseKafkaModel):
    _topic = 'subscription_events_extended'
 
    def __init__(self, subscriber_id: int, subscriber_uuid: str, channel_id: int, data_json: str = None, **kwargs):
        super().__init__(**kwargs)
        self.channel_id = channel_id
        self.subscriber_id = subscriber_id
        self.subscriber_uuid = subscriber_uuid
        self.data_json = data_json or '{}'
        self._data = SubscriptionEventExtendedData.from_json(self.data_json)