GeezerVison is showing github.com — StreamGuard/producer.js at main · codeterrayt/StreamGuard

Expand file tree

producer.js

Copy path

More file actions

38 lines (28 loc) · 808 Bytes

Copy path

38 lines (28 loc) · 808 Bytes

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

require('dotenv').config();

// producer.js

const { Kafka, Partitioners } = require('kafkajs');

const kafka = new Kafka({

clientId: process.env.KAFKA_CLIENT_ID,

brokers:[process.env.KAFKA_BROKER]

});

console.log({

clientId: process.env.KAFKA_CLIENT_ID,

brokers:[process.env.KAFKA_BROKER]

})

const producer = kafka.producer();

// const producer = kafka.producer({

// createPartitioner: Partitioners.LegacyPartitioner

// });

const connectProducer = async () => {

await producer.connect();

};

const sendMessage = async (topic, message) => {

await producer.send({

topic,

messages: [{ value: JSON.stringify(message) }],

});

};

const disconnectProducer = async () => {

await producer.disconnect();

};

module.exports = { connectProducer, sendMessage, disconnectProducer };