MQTT Sub nodejs

mqtt.js

const mqtt = require("mqtt");
const client = mqtt.connect("mqtt://event-bus:1883", {
  clientId: require('crypto').randomUUID(),
  clean: true,
  connectTimeout: 4000,
  username: 'emqx',
  password: 'public',
  reconnectPeriod: 1000,
});
client.on('connect', () => {
  console.log('Connected');
  client.subscribe("+", () => {
    client.on('message', (topic, message) => {
      console.log(`Received message "${message.toString()}" on topic "${topic}"`)
    })
  });
})

tcp.js

const net = require('net');

const server = net
  .createServer(socket => {
    socket.on('data', data => {
      console.log(data.toString());
    });
  })
  .on('error', err => {
    throw err;
  });

server.listen(8000, '0.0.0.0', undefined, () => {
  console.log('TCP server is listening on 0.0.0.0:8000');
});