Kafka Producer for Meteor?

help
1

Does meteor have any kafka package that ca be used to write a kafka producer?

2

You can try kafkajs.

meteor npm installl -save kafka

import {Kafka} from "kafkajs";

...

if (Meteor.isServer) {
			const kafka = new Kafka({
				clientId: "my-app",
				brokers: ["127.0.0.1:9092"],
			});

			const producer = kafka.producer();

			producer
				.connect()
				.then((result) => {
					console.log("Kafka");
					producer
						.send({
							topic: "events",
							messages: [{ value: "Hello KafkaJS user!" }],
						})
						.then((res) => {
							// to something
						})
						.catch((err) => {
							//Error
						});
				})
				.catch((err) => {
					// Error
				});
}
3

Meteor itself is agnostic to external systems, you can use whatever you like. We use kafka-node. I wasn’t even aware of kafkajs, as hinted by @harry73, so I can’t tell which one is better.