scalable-stream-processing distributed stream processing using faust and celery Installation make pg-kafka make api make stream make queue docker-compose scale queue=10 Locust Load Test make locust for locust test go to “http://localhost:8090/" Medium