chore: extra debug info, higher timeout

Author: AVVS

e2e/consumer.spec.js

@@ -66,7 +66,7 @@ describe('Consumer', function() {
     beforeEach(function(done) {
       consumer = new KafkaConsumer(gcfg, {});
 
-      consumer.connect({ timeout: 2000 }, function(err, info) {
+      consumer.connect({ timeout: 5000 }, function(err, info) {
         t.ifError(err);
         done();
       });

src/workers.cc

@@ -998,7 +998,7 @@ KafkaConsumerCommitted::KafkaConsumerCommitted(Nan::Callback *callback,
                                      KafkaConsumer* consumer,
                                      std::vector<RdKafka::TopicPartition*> & t,
                                      const int & timeout_ms) :
-  ErrorAwareWorker(callback),
+  ErrorAwareWorker(callback, "node-rdkafka::KafkaConsumerCommitted"),
   m_consumer(consumer),
   m_topic_partitions(t),
   m_timeout_ms(timeout_ms) {}