Message broker features with example

Working on microservices architecture, I am trying to create consummer with kafka, I putted in on the queueInLoop function of drogon::app() but I don't know if it is a good practice or not. It would be good to have an example with message broker with producer and consumer to see how it can be works with drogon c++ !
Thanks you for your work !