From f5b9d802e562b47dc9125f262aa2a51fb9f3c71b Mon Sep 17 00:00:00 2001 From: Stephen Parente Date: Mon, 12 Feb 2018 12:31:15 -0800 Subject: [PATCH] Version bump to 2.2.3 --- lib/kafka-consumer.js | 11 +++++------ package.json | 2 +- 2 files changed, 6 insertions(+), 7 deletions(-) diff --git a/lib/kafka-consumer.js b/lib/kafka-consumer.js index 77586adf..e70140f6 100644 --- a/lib/kafka-consumer.js +++ b/lib/kafka-consumer.js @@ -204,7 +204,7 @@ KafkaConsumer.prototype.committed = function(toppars, timeout, cb) { * @example * consumer.seek({ topic: 'topic', partition: 0, offset: 1000 }, 0, function(err) { * if (err) { - * + * * } * }); * @@ -472,8 +472,8 @@ KafkaConsumer.prototype._consumeNum = function(timeoutMs, numMessages, cb) { * If you provide a topic partition, it will commit that. Otherwise, * it will commit all read offsets for all topic partitions. * - * @param {object|null} - Topic partition object to commit, or null if you - * are going to commit all read offsets. + * @param {object|array|null} - Topic partition object to commit, list of topic + * partitions, or null if you want to commit all read offsets. * @throws When commit returns a non 0 error code * * @return {KafkaConsumer} - returns itself. @@ -508,9 +508,8 @@ KafkaConsumer.prototype.commitMessage = function(msg) { /** * Commit a topic partition (or all topic partitions) synchronously * - * @param {object|null} - Topic partition object to commit, or null if you - * are going to commit all read offsets. - * + * @param {object|array|null} - Topic partition object to commit, list of topic + * partitions, or null if you want to commit all read offsets. * @throws {LibrdKafkaError} - if the commit fails * * @return {KafkaConsumer} - returns itself. diff --git a/package.json b/package.json index edc48a82..79496f13 100644 --- a/package.json +++ b/package.json @@ -1,6 +1,6 @@ { "name": "node-rdkafka", - "version": "2.2.2", + "version": "2.2.3", "description": "Node.js bindings for librdkafka", "main": "lib/index.js", "scripts": {