Simple example of how to publish and consume data from kafka stream service using kafkajs library.
Enter in project folder and run the command bellow
docker-compose up -d
after that enter in consumer and producer folder and install packagens with:
npm install
After installation you can start the producer and consumer with:
node ./producer/index.js
node ./consumer/index.js