bytewax для процессинга Kafka и подобных

Фреймворк объединяет обработку потоков и событий Flink, Spark и Kafka Streams и других аналогичных решений.

Можно подключать источники данных, выполнять преобразования и записывать с помощью встроенных коннекторов или существующих Py-библиотек.

Проект на GitHub

#фреймворк

@zen_of_python