https://medium.com/distributed-computing-with-ray/serverless-kafka-stream-processing-with-ray-674e7028ce7d