no-kafka - npm Package Compare versions

Comparing version 2.0.7 to 2.0.8

lib/bluebird-configured.js

lib/base_consumer.js

		'use strict';

		var Promise = require('bluebird');
		var Promise = require('./bluebird-configured');
		var _ = require('lodash');
		@@ -5,0 +5,0 @@ var Client = require('./client');

lib/client.js

		'use strict';

		var Promise = require('bluebird');
		var Connection = require('./connection');
		var Protocol = require('./protocol');
		var errors = require('./errors');
		var _ = require('lodash');
		var Logger = require('nice-simple-logger');
		var Promise = require('./bluebird-configured');
		var Connection = require('./connection');
		var Protocol = require('./protocol');
		var errors = require('./errors');
		var _ = require('lodash');
		var Logger = require('nice-simple-logger');
		var compression = require('./protocol/misc/compression');
		@@ -10,0 +10,0 @@

lib/connection.js

		'use strict';

		var net = require('net');
		var Promise = require('bluebird');
		var Promise = require('./bluebird-configured');
		var NoKafkaConnectionError = require('./errors').NoKafkaConnectionError;
		@@ -6,0 +6,0 @@

lib/group_consumer.js

		'use strict';

		var Promise = require('bluebird');
		var Promise = require('./bluebird-configured');
		var _ = require('lodash');
		@@ -5,0 +5,0 @@ var BaseConsumer = require('./base_consumer');

lib/index.js

		@@ -6,8 +6,3 @@ 'use strict';
		var WRRPool = require('wrr-pool');
		var Promise = require('bluebird');

		Promise.config({
		cancellation: true
		});

		exports.ConsistentAssignment = function (subscriptions) { // [{topic:String, members:[], partitions:[]}]
		@@ -14,0 +9,0 @@ var result = [];

lib/producer.js

		'use strict';

		var Promise = require('bluebird');
		var Promise = require('./bluebird-configured');
		var _ = require('lodash');
		@@ -5,0 +5,0 @@ var Client = require('./client');

lib/simple_consumer.js

		'use strict';

		var Promise = require('bluebird');
		var Promise = require('./bluebird-configured');
		var _ = require('lodash');
		@@ -5,0 +5,0 @@ var BaseConsumer = require('./base_consumer');

package.json

README.md

		@@ -10,4 +10,5 @@ [![Build Status][badge-travis]][travis]
		__no-kafka__ is [Apache Kafka](https://kafka.apache.org) 0.9 client for Node.js with [new unified consumer API](#groupconsumer-new-unified-consumer-api) support.
		__no-kafka__ supports sync and async Gzip and Snappy compression, producer batching and controllable retries, offers few predefined group assignment strategies and producer partitioner option.

		Supports sync and async Gzip and Snappy compression, producer batching and controllable retries, offers few predefined group assignment strategies and producer partitioner option.

		All methods will return a [promise](https://github.com/petkaantonov/bluebird)
		@@ -14,0 +15,0 @@

New alerts