kafka
Platypush documentation
kafka
- class platypush.plugins.kafka.KafkaPlugin(server=None, port=9092, **kwargs)[source]
Bases:
Plugin
Plugin to send messages to an Apache Kafka instance (https://kafka.apache.org/)
Triggers:
platypush.message.event.kafka.KafkaMessageEvent
when a new message is received on the consumer topic.
Requires:
kafka (
pip install kafka-python
)