- npm i
- make .env file with KAFKA_HOST and KAFKA_PORT (defaults are localhost and 9092)
- npm run start
- send message to test1 topic (you can use message.kafka file with VScode extension)
- send message to test2 topic
messages both received and processed at the same time
messages are processed in a row
You can see CPU profile in a root folder (run.cpuprofile file)
Flame graphs:
Issue occured after updating to nestjs version 10.x