codes

Author: Jayakrishnan JR

config.js

@@ -0,0 +1,4 @@
+module.exports = {
+  kafka_topic: 'example',
+  kafka_server: 'localhost:2181',
+};

consumer.app.js

@@ -0,0 +1,33 @@
+
+const kafka = require('kafka-node');
+const bp = require('body-parser');
+const config = require('./config');
+
+try {
+  const Consumer = kafka.HighLevelConsumer;
+  const client = new kafka.Client(config.kafka_server);
+  let consumer = new Consumer(
+    client,
+    [{ topic: config.kafka_topic, partition: 0 }],
+    {
+      autoCommit: true,
+      fetchMaxWaitMs: 1000,
+      fetchMaxBytes: 1024 * 1024,
+      encoding: 'utf8',
+      fromOffset: false
+    }
+  );
+  consumer.on('message', async function(message) {
+    console.log('here');
+    console.log(
+      'kafka-> ',
+      message.value
+    );
+  })
+  consumer.on('error', function(err) {
+    console.log('error', err);
+  });
+}
+catch(e) {
+  console.log(e);
+}