diff --git a/lib/kafka-consumer.js b/lib/kafka-consumer.js index cdfee30d..875a3779 100644 --- a/lib/kafka-consumer.js +++ b/lib/kafka-consumer.js @@ -58,7 +58,7 @@ function KafkaConsumer(conf, topicConf) { // Emit the event self.emit('rebalance', err, assignment); - // That's it + // That's it. try { if (err.code === -175 /*ERR__ASSIGN_PARTITIONS*/) { if (self.rebalanceProtocol() === 'COOPERATIVE') {