kafka-node refreshMetadataError

error

kafka-node:KafkaClient Connect attempt 1 +0ms
kafka-node:KafkaClient Trying to connect to host: 192.168.0.150 port: 9092 +3ms
kafka-node:KafkaClient kafka-node-client createBroker 192.168.0.150:9092 +1ms
kafka-node:KafkaClient kafka-node-client sending versions request to 192.168.0.150:9092 +902ms
kafka-node:KafkaClient broker socket connected {"host":"192.168.0.150","port":"9092"} +3ms
kafka-node:KafkaClient connected to socket, trying to load initial metadata +2ms
kafka-node:KafkaClient missing apiSupport waiting until broker is ready... +1ms
kafka-node:KafkaClient waitUntilReady [BrokerWrapper 192.168.0.150:9092 (connected: true) (ready: false) (idle: false) (needAuthentication: false) (authenticated: false)] +1ms
kafka-node:KafkaClient Received versions response from 192.168.0.150:9092 +69ms
kafka-node:KafkaClient setting api support to {"21":{"min":0,"max":1,"usable":false},"22":{"min":0,"max":1,"usable":false},"23":{"min":0,"max":2,"usable":false},"24":{"min":0,"max":1,"usable":false},"25":{"min":0,"max":1,"usable":false},"26":{"min":0,"max":1,"usable":false},"27":{"min":0,"max":0,"usable":false},"28":{"min":0,"max":2,"usable":false},"29":{"min":0,"max":1,"usable":false},"30":{"min":0,"max":1,"usable":false},"31":{"min":0,"max":1,"usable":false},"33":{"min":0,"max":1,"usable":false},"34":{"min":0,"max":1,"usable":false},"35":{"min":0,"max":1,"usable":false},"37":{"min":0,"max":1,"usable":false},"38":{"min":0,"max":1,"usable":false},"39":{"min":0,"max":1,"usable":false},"40":{"min":0,"max":1,"usable":false},"41":{"min":0,"max":1,"usable":false},"42":{"min":0,"max":1,"usable":false},"produce":{"min":0,"max":7,"usable":2},"fetch":{"min":0,"max":10,"usable":2},"offset":{"min":0,"max":4,"usable":0},"metadata":{"min":0,"max":7,"usable":1},"leader":{"min":0,"max":1,"usable":false},"stopReplica":{"min":0,"max":0,"usable":false},"updateMetadata":{"min":0,"max":4,"usable":false},"controlledShutdown":{"min":0,"max":1,"usable":false},"offsetCommit":{"min":0,"max":6,"usable":2},"offsetFetch":{"min":0,"max":5,"usable":1},"groupCoordinator":{"min":0,"max":2,"usable":0},"joinGroup":{"min":0,"max":3,"usable":0},"heartbeat":{"min":0,"max":2,"usable":0},"leaveGroup":{"min":0,"max":2,"usable":0},"syncGroup":{"min":0,"max":2,"usable":0},"describeGroups":{"min":0,"max":2,"usable":0},"listGroups":{"min":0,"max":2,"usable":0},"saslHandshake":{"min":0,"max":1,"usable":1},"apiVersions":{"min":0,"max":2,"usable":0},"createTopics":{"min":0,"max":3,"usable":1},"deleteTopics":{"min":0,"max":3,"usable":false},"describeConfigs":{"min":0,"max":2,"usable":0},"saslAuthenticate":{"min":0,"max":0,"usable":0}} +0ms
kafka-node:KafkaClient broker is now ready +1ms
kafka-node:KafkaClient kafka-node-client updated internal metadata +82ms
kafka-node:KafkaClient socket.on(close), calling refreshBrokerMetadata() +10m
kafka-node:KafkaClient kafka-node-client refreshBrokerMetadata() +0ms

events.js:167
throw er; // Unhandled 'error' event
^
NestedError: refreshBrokerMetadata failed
at async.waterfall (/Users/wizzcheez/projects/node-api-server/node_modules/kafka-node/lib/kafkaClient.js:377:35)
at /Users/wizzcheez/projects/node-api-server/node_modules/kafka-node/node_modules/async/dist/async.js:473:16
at next (/Users/wizzcheez/projects/node-api-server/node_modules/kafka-node/node_modules/async/dist/async.js:5329:29)
at /Users/wizzcheez/projects/node-api-server/node_modules/kafka-node/node_modules/async/dist/async.js:969:16
at KafkaClient.getAvailableBroker (/Users/wizzcheez/projects/node-api-server/node_modules/kafka-node/lib/kafkaClient.js:329:12)
at async.waterfall.callback (/Users/wizzcheez/projects/node-api-server/node_modules/kafka-node/lib/kafkaClient.js:372:23)
at nextTask (/Users/wizzcheez/projects/node-api-server/node_modules/kafka-node/node_modules/async/dist/async.js:5324:14)
at Object.waterfall (/Users/wizzcheez/projects/node-api-server/node_modules/kafka-node/node_modules/async/dist/async.js:5334:5)
at KafkaClient.refreshBrokerMetadata (/Users/wizzcheez/projects/node-api-server/node_modules/kafka-node/lib/kafkaClient.js:371:9)
at Immediate._onImmediate (/Users/wizzcheez/projects/node-api-server/node_modules/kafka-node/lib/kafkaClient.js:780:20)
Caused By: Error: Unable to find available brokers to try
at KafkaClient.getAvailableBroker (/Users/wizzcheez/projects/node-api-server/node_modules/kafka-node/lib/kafkaClient.js:329:21)
at async.waterfall.callback (/Users/wizzcheez/projects/node-api-server/node_modules/kafka-node/lib/kafkaClient.js:372:23)
at nextTask (/Users/wizzcheez/projects/node-api-server/node_modules/kafka-node/node_modules/async/dist/async.js:5324:14)
at Object.waterfall (/Users/wizzcheez/projects/node-api-server/node_modules/kafka-node/node_modules/async/dist/async.js:5334:5)
at KafkaClient.refreshBrokerMetadata (/Users/wizzcheez/projects/node-api-server/node_modules/kafka-node/lib/kafkaClient.js:371:9)
at Immediate._onImmediate (/Users/wizzcheez/projects/node-api-server/node_modules/kafka-node/lib/kafkaClient.js:780:20)
at runCallback (timers.js:705:18)
at tryOnImmediate (timers.js:676:5)
at processImmediate (timers.js:658:5)
Emitted 'error' event at:
  at KafkaClient.<anonymous> (/Users/wizzcheez/projects/node-api-server/node_modules/kafka-node/lib/baseProducer.js:101:10)
at KafkaClient.emit (events.js:182:13)
at async.waterfall (/Users/wizzcheez/projects/node-api-server/node_modules/kafka-node/lib/kafkaClient.js:377:21)
at /Users/wizzcheez/projects/node-api-server/node_modules/kafka-node/node_modules/async/dist/async.js:473:16
  [... lines matching original stack trace ...]
at Object.waterfall (/Users/wizzcheez/projects/node-api-server/node_modules/kafka-node/node_modules/async/dist/async.js:5334:5)