- Currently confluent kafka library does not support async, we have to find a way to improve this and avoid blocking the tasks
