@@ -204,7 +204,7 @@ KafkaConsumer.prototype.committed = function(toppars, timeout, cb) {
204
204
* @example
205
205
* consumer.seek({ topic: 'topic', partition: 0, offset: 1000 }, 0, function(err) {
206
206
* if (err) {
207
- *
207
+ *
208
208
* }
209
209
* });
210
210
*
@@ -472,8 +472,8 @@ KafkaConsumer.prototype._consumeNum = function(timeoutMs, numMessages, cb) {
472
472
* If you provide a topic partition, it will commit that. Otherwise,
473
473
* it will commit all read offsets for all topic partitions.
474
474
*
475
- * @param {object|null } - Topic partition object to commit, or null if you
476
- * are going to commit all read offsets.
475
+ * @param {object|array| null } - Topic partition object to commit, list of topic
476
+ * partitions, or null if you want to commit all read offsets.
477
477
* @throws When commit returns a non 0 error code
478
478
*
479
479
* @return {KafkaConsumer } - returns itself.
@@ -508,9 +508,8 @@ KafkaConsumer.prototype.commitMessage = function(msg) {
508
508
/**
509
509
* Commit a topic partition (or all topic partitions) synchronously
510
510
*
511
- * @param {object|null } - Topic partition object to commit, or null if you
512
- * are going to commit all read offsets.
513
- *
511
+ * @param {object|array|null } - Topic partition object to commit, list of topic
512
+ * partitions, or null if you want to commit all read offsets.
514
513
* @throws {LibrdKafkaError } - if the commit fails
515
514
*
516
515
* @return {KafkaConsumer } - returns itself.
0 commit comments