flask
confluent_kafka
pyflink
