kafka-node - npm Package Compare versions

Comparing version 4.1.1 to 4.1.2

CHANGELOG.md

		# kafka-node CHANGELOG

		## 2019-04-30, Version 4.1.2
		* Fix getController not returning controller Id [#1247](https://github.com/SOHU-Co/kafka-node/pull/1247)

		## 2019-04-16, Version 4.1.1
		@@ -4,0 +7,0 @@ * Fix ConsumerGroup receiving wrong offsets for compressed messages [#1236](https://github.com/SOHU-Co/kafka-node/pull/1236)

lib/kafkaClient.js

		@@ -289,3 +289,3 @@ 'use strict';

		return callback(null, broker);
		return callback(null, broker, this.clusterMetadata.controllerId);
		});
		@@ -292,0 +292,0 @@ };

package.json

		@@ -17,3 +17,3 @@ {
		"bugs": "https://github.com/SOHU-co/kafka-node/issues",
		"version": "4.1.1",
		"version": "4.1.2",
		"main": "kafka.js",
		@@ -20,0 +20,0 @@ "types": "types/index.d.ts",

README.md

		@@ -159,3 +159,2 @@ Kafka-node
		```
		> ⚠️WARNING: Batch multiple messages of the same topic/partition together as an array on the `messages` attribute otherwise you may lose messages!

		@@ -272,3 +271,2 @@ ### createTopics(topics, cb)
		```
		> ⚠️WARNING: Batch multiple messages of the same topic/partition together as an array on the `messages` attribute otherwise you may lose messages!

		@@ -569,4 +567,2 @@ ### createTopics(topics, async, cb)
		outOfRangeOffset: 'earliest', // default
		migrateHLC: false, // for details please see Migration section below
		migrateRolling: true,
		// Callback to allow consumers with autoCommit false a chance to commit before a rebalance finishes
		@@ -573,0 +569,0 @@ // isAlreadyMember will be false on the first connection, and true on rebalances triggered after that

New alerts