Simple producer-consumer using kafkajs
depends on
- npm / node
- docker / docker-compose
- run
npm install
- run
docker-compose up
- start the consumer
node consumer.js
it should connect to the single-cluster local kafka installation - every time the producer is ran, the consumer should see a single new message
node producer.js