Need to improve the overall latency and scalability by integrating message queueing protocols. (Preferably: Kafkajs)