1.0.2 • Published 2 years ago
publisher-kafka v1.0.2
#publisher-kafka package eg :
const publisher = require("publisher-kafka")
let clientId = 'my-app' let brokerArray = 'localhost:9092' let publishInstance = new publisher(clientId, brokerArray)
let ObjToSend = { topic: 'tasklist_received', messages: { value: 'Hello KafkaJS user2!' }, , }
publishInstance.publish(ObjToSend )