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
