oleksiyk/kafka

File group_consumer.js has 260 lines of code (exceeds 250 allowed). Consider refactoring.

Open

'use strict';

var Promise      = require('./bluebird-configured');
var _            = require('lodash');
var BaseConsumer = require('./base_consumer');

Function _syncGroup has 46 lines of code (exceeds 25 allowed). Consider refactoring.

Open

GroupConsumer.prototype._syncGroup = function () {
    var self = this;

    return Promise.try(function () {
        if (self.memberId === self.leaderId) { // leader should generate group assignments

Function init has 30 lines of code (exceeds 25 allowed). Consider refactoring.

Open

GroupConsumer.prototype.init = function (strategies) {
    var self = this;

    return BaseConsumer.prototype.init.call(self).then(function () {
        if (_.isEmpty(strategies)) {

Function _updateSubscriptions has 29 lines of code (exceeds 25 allowed). Consider refactoring.

Open

GroupConsumer.prototype._updateSubscriptions = function (partitionAssignment) {
    var self = this, offsetRequests = [],
        handler = self.strategies[self.strategyName].handler;

    self.subscriptions = {};

Function _joinGroup has 26 lines of code (exceeds 25 allowed). Consider refactoring.

Open

GroupConsumer.prototype._joinGroup = function () {
    var self = this;

    return (function _tryJoinGroup(attempt) {
        attempt = attempt || 0;

Similar blocks of code found in 2 locations. Consider refactoring.

Open

        return self.client.joinConsumerGroupRequest(self.options.groupId, self.memberId, self.options.sessionTimeout, _.values(self.strategies))
        .catch({ code: 'GroupCoordinatorNotAvailable' }, function () {
            return Promise.delay(1000).then(function () {
                return _tryJoinGroup(++attempt);
            });

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

        return self._joinGroup().then(function () {
            return self._syncGroup();
        })
        .catch({ code: 'RebalanceInProgress' }, function () {
            return Promise.delay(1000).then(function () {

• Read up
  Read up