How to Consume Kafka Messages With NestJS

This story was originally published on HackerNoon at: https://hackernoon.com/how-to-consume-kafka-messages-with-nestjs.
In this article I will tell you how to implement your own kafka message consumer using the NestJs framework. I’ll also tell you how to write tests for it.
Check more stories related to programming at: https://hackernoon.com/c/programming. You can also check exclusive content about #kafka, #nestjs, #typescript, #docker, #testcontainers, #consume-kafka-messages-guide, #hackernoon-top-story, #kafka-tips-and-tricks, #hackernoon-es, #hackernoon-hi, #hackernoon-zh, #hackernoon-fr, #hackernoon-bn, #hackernoon-ru, #hackernoon-vi, #hackernoon-pt, #hackernoon-ja, #hackernoon-de, #hackernoon-ko, #hackernoon-tr, and more.

This story was written by: @vdolzhenko. Learn more about this writer by checking @vdolzhenko's about page, and for more stories, please visit hackernoon.com.

Kafka is a message broker in which some services generate messages and others receive them. In this article we will write a small application for consuming messages from kafka. And of course e2e tests. First we need to create a controller that will process messages. Then run the microservices in the main services in the NestJs framework.