import ContentTransmitter from "knamp-content-transmitter";
 
(async () => {
 
  const processor = await ContentTransmitter({
    clientName: "transmitter-client",
    consumeFrom: "transmitter-consume",
    groupId: "transmitter-group",
    produceTo: "generator-consume",
  });
 
  processor.on("error", (error) => {
    console.error(error);
  });
})();