feat: producer consumer

Author: thutasann

standalone-apis/node-kafka-producer-consumer/consumer/index.js

@@ -0,0 +1,22 @@
+// @ts-check
+import Kafka from 'node-rdkafka';
+
+const consumer = new Kafka.KafkaConsumer(
+	{
+		'group.id': 'kafka',
+		'metadata.broker.list': 'localhost:9092',
+	},
+	{},
+);
+
+consumer.connect();
+
+consumer
+	.on('ready', () => {
+		console.log('consumer ready...');
+		consumer.subscribe(['test']);
+		consumer.consume();
+	})
+	.on('data', (data) => {
+		console.log(`received message : ${data.value} ⭐️`);
+	});

standalone-apis/node-kafka-producer-consumer/package-lock.json

@@ -0,0 +1,18 @@
+{
+  "name": "kafka-producer-consumer",
+  "version": "1.0.0",
+  "description": "## Create Kafka Topic",
+  "main": "index.js",
+  "type": "module",
+  "scripts": {
+    "start:producer": "node ./producer/index.js",
+    "start:consumer": "node ./consumer/index.js"
+  },
+  "keywords": [],
+  "author": "",
+  "license": "ISC",
+  "dependencies": {
+    "avsc": "^5.7.7",
+    "node-rdkafka": "^3.2.1"
+  }
+}

standalone-apis/node-kafka-producer-consumer/package.json

@@ -0,0 +1,24 @@
+// @ts-check
+import Kafka from 'node-rdkafka';
+
+const stream = Kafka.Producer.createWriteStream(
+	{
+		'metadata.broker.list': 'localhost:9092',
+	},
+	{},
+	{ topic: 'test' },
+);
+
+/** Queue message */
+function queueMessage() {
+	const success = stream.write(Buffer.from(`hi from producer`));
+	if (success) {
+		console.log('message wrote successfully to stream. ✅');
+	} else {
+		console.log('something went wrong..');
+	}
+}
+
+setInterval(() => {
+	queueMessage();
+}, 3000);