kafka

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

Bases: Event

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