Consumer is not going in ready state and hence it is not consuming any message

[codersneha3012]

Here is my code ` var app = require('express')(); var http = require('http').createServer(app); var cors = require('cors') var io = require('socket.io')(http); const utf8 = require('utf8'); var kafka = require('kafka-node');

app.use(cors())

app.get('/', (req, res) => { res.send('

Hello world

'); });

//io.on('connection', (socket) => { // console.log('a user connected'); // socket.on('disconnect', () => { // console.log('user disconnected'); // }); //}); var Consumer = kafka.Consumer, client = new kafka.KafkaClient({kafkaHost: 'localhost:9092'});

client.on('ready', ()=>{ console.log('client ready'); });

const nsp = io.of('/EAP'); nsp.on('connection', function(socket){ console.log('someone connected', new Date().toLocaleString()); socket.on('disconnect', () => { console.log('someone disconnected', new Date().toLocaleString()); }); }); var consumer = new Consumer(client,[{ topic: 'test-topic2', partition: 0 }],{groupId: 'kafka-node-group',autoCommit: false});

consumer.on('ready', ()=>{ console.log('c ready'); }); consumer.on('message', function (message) { console.log("Message found in consumer", new Date().toLocaleString()); // data = JSON.parse(utf8.decode(message)) // nsp.emit(data); }); consumer.on('error', function (err) {console.log("Error in consuming", new Date().toLocaleString())}) consumer.commit(function(err, data) {});

http.listen(8002, () => { console.log('listening on *:8002'); }); `

And the output is listening on *:8002 client ready someone connected 5/23/2020, 6:35:18 PM someone connected 5/23/2020, 6:35:21 PM

So the client is not going in ready state. What could be possible reason?

[daniel347x]

Did you ever figure this out? I am getting exactly the same thing.

[jaymovaliya]

I am also getting same error, Have you figured it out?

[traoremp]

Same here .. @codersneha3012 @daniel347x @jaymovaliya Did any of you figure this out ?