- start the zk+broker combo here:
yarn run kafka:start - run
node producer.jsand wait until the producer is connected and sending (as the broker will have to create the topic during the first start) - run
node consumer.jsto receive the produced messages
use debug mode to see mo information, e.g
DEBUG=* node producer.js