Currently i'm implementing the Kafka Queue with Node.js. I can able to create the simple API in Ex