4 ms·
I'd love to see some docs/examples around supporting pluggable brokers; Faust looks like exactly what I want from a python stream processor, but for various tec
by adambard 8y ago
I'd love to see some docs/examples around supporting pluggable brokers; Faust looks like exactly what I want from a python stream processor, but for various technical and operational reasons it would be nice to be able to provide a RabbitMQ/AMQP broker.
- asksol 8y agoWe added two levels of abstractions for this purpose: - A Stream iterates over a channel - A Channel implements: `channel.send` and `channel.__aiter__`. - A topic is a "named" channel backed by a Kafka topic - Further the topic is backed by a Transport - Transport is very Kafka specific To implement support for AMQP the idea is you only need to implement a custom channel. If you open an issue we can consider how to best implement it.