const memphis = require("memphis-dev");
host: "broker.sandbox.memphis.dev",
connectionToken: "XrHmszw6rgm8IyOPNNTy"
const consumer = await memphis.consumer({
stationName: "hello_world",
consumerName: "consumer_app1",
consumerGroup: "consumer_group1"
consumer.on("message", message => {
console.log(message.getData().toString());
consumer.on("error", error => {
const producer = await memphis.producer({
stationName: "hello_world",
producerName: "producer_app"
for (let index = 0; index < 100; index++) {
message: Buffer.from('Hello world')
console.log("Message sent");
console.log("All messages sent");