		{
		"name": "kafkajs",
		"version": "1.13.0-beta.20",
		"version": "1.13.0-beta.21",
		"description": "A modern Apache Kafka client for node.js",
		@@ -82,5 +82,5 @@ "author": "Tulio Ornelas <ornelas.tulio@gmail.com>",
		"kafkajs": {
		"sha": "7eaa3539c0135f4ced9da33a3a457acab147453f",
		"compare": "https://github.com/tulios/kafkajs/compare/v1.12.0...7eaa3539c0135f4ced9da33a3a457acab147453f"
		"sha": "c51dda6fd3d1626535cd7a44e763426e317f2d3a",
		"compare": "https://github.com/tulios/kafkajs/compare/v1.12.0...c51dda6fd3d1626535cd7a44e763426e317f2d3a"
		}
		}

README.md

		@@ -86,3 +86,3 @@ # <a href='https://kafka.js.org'><img src='https://raw.githubusercontent.com/tulios/kafkajs/master/logoV2.png' height='60' alt='KafkaJS' aria-label='kafka.js.org' /></a>

		KafkaJS is an open-source project where development takes place in the open on GitHub. Although the project is maintained by a small group of dedicated volunteers, we are grateful to the community for bugfixes, feature development and other contributions.
		KafkaJS is an open-source project where development takes place in the open on GitHub. Although the project is maintained by a small group of dedicated volunteers, we are grateful to the community for bug fixes, feature development and other contributions.

		@@ -89,0 +89,0 @@ See [Developing KafkaJS](https://kafka.js.org/docs/contribution-guide) for information on how to run and develop KafkaJS.

src/consumer/consumerGroup.js

		@@ -220,3 +220,3 @@ const flatten = require('../utils/flatten')

		// If the consumer is not aware of all assigned partions, refresh metadata
		// If the consumer is not aware of all assigned partitions, refresh metadata
		// and update the list of partitions per subscribed topic. It's enough to perform
		@@ -223,0 +223,0 @@ // this operation once since refresh metadata will update metadata for all topics

src/consumer/index.js

		@@ -339,3 +339,3 @@ const Long = require('long')
		throw new KafkaJSNonRetriableError(
		`Invalid offset metatadta, expected string or null, received ${metadata}`
		`Invalid offset metadata, expected string or null, received ${metadata}`
		)
		@@ -342,0 +342,0 @@ }

src/producer/index.js

		@@ -86,3 +86,3 @@ const createRetry = require('../retry')
		* Begin a transaction. The returned object contains methods to send messages
		* to the transaction and end the transaction by comitting or aborting.
		* to the transaction and end the transaction by committing or aborting.
		*
		@@ -89,0 +89,0 @@ * Only messages sent on the transaction object will participate in the transaction.

kafkajs - npm Package Compare versions

Improved metrics