Description
class MessageCallbackRawEvent(BaseKafkaModel):
_topic = 'message_callbacks_raw'
def __init__(self, callback_type: str, data_json: str, **kwargs):
super(MessageCallbackRawEvent, self).__init__(**kwargs)
self.callback_type = callback_type
self.data_json = data_json