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