You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
new kafka.Consumer().connect().subscribeTopic('juggernaut')
console.log("Consumed message:", message)
})
Throws
TypeError: Cannot read property 'length' of undefined
at [object Object]._encodeFetchRequest (/Users/yankov/ruby/fix/node_modules/kafka/lib/Client.js:99:26)
at [object Object]. (/Users/yankov/ruby/fix/node_modules/kafka/lib/Client.js:33:16)
at Object.encode (native)
at [object Object]._writeRequest (/Users/yankov/ruby/fix/node_modules/kafka/lib/Client.js:94:55)
at [object Object]._onConnect (/Users/yankov/ruby/fix/node_modules/kafka/lib/Client.js:85:34)
at Socket.bound (/Users/yankov/ruby/fix/node_modules/kafka/node_modules/std/bind.js:47:17)
at Socket.emit (events.js:81:20)
at Socket._onConnect (net.js:588:12)
at IOWatcher.onWritable as callback
It looks like when iterating topics it gets functions from Array for some reason and then tries to threat them as real topics.
The text was updated successfully, but these errors were encountered:
Code to reproduce
Array.prototype.include = function(value) {};
var kafka = require('kafka')
new kafka.Consumer().connect().subscribeTopic('juggernaut')
console.log("Consumed message:", message)
})
Throws
TypeError: Cannot read property 'length' of undefined
at [object Object]._encodeFetchRequest (/Users/yankov/ruby/fix/node_modules/kafka/lib/Client.js:99:26)
at [object Object]. (/Users/yankov/ruby/fix/node_modules/kafka/lib/Client.js:33:16)
at Object.encode (native)
at [object Object]._writeRequest (/Users/yankov/ruby/fix/node_modules/kafka/lib/Client.js:94:55)
at [object Object]._onConnect (/Users/yankov/ruby/fix/node_modules/kafka/lib/Client.js:85:34)
at Socket.bound (/Users/yankov/ruby/fix/node_modules/kafka/node_modules/std/bind.js:47:17)
at Socket.emit (events.js:81:20)
at Socket._onConnect (net.js:588:12)
at IOWatcher.onWritable as callback
It looks like when iterating topics it gets functions from Array for some reason and then tries to threat them as real topics.
The text was updated successfully, but these errors were encountered: