Correct, here is their Kafka-based stream processing package that presumably ties everything together: https://faust.readthedocs.io/en/latest/