Prerequisites node docker Running locally ./scripts/start-kafka.sh - starts kafka inside docker container. ./scripts/create-topic.sh - creates kafka topic. npm run start:producer - starts producer. npm run start:consumer - starts consumer.