Fixes #446

lib/client.js

@@ -131,7 +131,7 @@ Client.prototype.setupBrokerProfiles = function (brokers) {
     var addr;
 
     if (brokerProfile.endpoints && brokerProfile.endpoints.length) {
-      var endpoint = brokerProfile.endpoints.find(function (endpoint) {
+      var endpoint = _.find(brokerProfile.endpoints, function (endpoint) {
         return url.parse(endpoint).protocol === protocol;
       });
 

test/helpers/Childrearer.js

@@ -1,4 +1,4 @@
-var EventEmitter = require('events');
+var EventEmitter = require('events').EventEmitter;
 var util = require('util');
 var debug = require('debug')('kafka-node:Test-Childrearer');
 var fork = require('child_process').fork;

test/mocks/mockClient.js

@@ -1,5 +1,5 @@
 var util = require('util');
-var EventEmitter = require('events');
+var EventEmitter = require('events').EventEmitter;
 var FakeZookeeper = require('./mockZookeeper');
 
 function FakeClient () {

test/mocks/mockSocket.js

@@ -1,5 +1,5 @@
 var util = require('util');
-var EventEmitter = require('events');
+var EventEmitter = require('events').EventEmitter;
 
 function FakeSocket () {
   EventEmitter.call(this);

test/mocks/mockZookeeper.js

@@ -1,5 +1,5 @@
 var util = require('util');
-var EventEmitter = require('events');
+var EventEmitter = require('events').EventEmitter;
 
 function FakeZookeeper () {
   EventEmitter.call(this);