platypush.message.event.kafka

class platypush.message.event.kafka.KafkaMessageEvent(msg, *args, **kwargs)[source]

Kafka message event object. Fired when platypush.backend.kafka receives a new event.

__init__(msg, *args, **kwargs)[source]
Parameters:msg (str or bytes stream) – Received message