Fixed CI errors

Author: webmakersteve

e2e/both.spec.js

@@ -75,18 +75,14 @@ var testCase = new TestCase('Interoperability tests', function() {
 
         crypto.randomBytes(4096, function(ex, buffer) {
 
-          consumer.on('rebalance', function(e) {
-            if (e.code === 500) {
-              setTimeout(function() {
-                producer.produce({
-                  message: buffer,
-                  topic: topic
-                }, function(err) {
-                  t.ifError(err);
-                });
-              }, 1000);
-            }
-          });
+          setTimeout(function() {
+            producer.produce({
+              message: buffer,
+              topic: topic
+            }, function(err) {
+              t.ifError(err);
+            });
+          }, 2000);
 
           var tt = setInterval(function() {
             if (!producer.isConnected()) {

src/callbacks.cc

@@ -460,12 +460,9 @@ Rebalance::Rebalance(v8::Local<v8::Function> &cb) {
 Rebalance::~Rebalance() {}
 
 void Rebalance::rebalance_cb(RdKafka::KafkaConsumer *consumer,
-  RdKafka::ErrorCode err,
-  std::vector<RdKafka::TopicPartition*> &partitions) {
-
+    RdKafka::ErrorCode err, std::vector<RdKafka::TopicPartition*> &partitions) {
   dispatcher.Add(rebalance_event_t(err, partitions));
   dispatcher.Execute();
-
 }
 
 // Partitioner callback

src/config.cc

@@ -71,7 +71,6 @@ Conf * Conf::create(RdKafka::Conf::ConfType type, v8::Local<v8::Object> object,
   }
 
   return rdconf;
-
 }
 
 void Conf::listen() {

src/config.h

@@ -14,6 +14,7 @@
 #include <iostream>
 #include <vector>
 #include <list>
+#include <string>
 
 #include "deps/librdkafka/src-cpp/rdkafkacpp.h"
 #include "src/common.h"
@@ -26,7 +27,6 @@ class Conf : public RdKafka::Conf {
   ~Conf();
 
   static Conf* create(RdKafka::Conf::ConfType, v8::Local<v8::Object>, std::string &);  // NOLINT
-
   static void DumpConfig(std::list<std::string> *);
 
   void listen();