fix: change param type

martijnimhoff · martijnimhoff · commit dd7550f203ce · 2024-01-24T07:42:49.000+01:00
diff --git a/lib/kafka-consumer.js b/lib/kafka-consumer.js
@@ -371,7 +371,7 @@ KafkaConsumer.prototype.unsubscribe = function() {
  * consumer can be subscribed to multiple topics.
  *
  * @param {number} size - Number of messages to read
- * @param {number} topic - Name of topic to read
+ * @param {string} topic - Name of topic to read
  * @param {number} partition - Identifier of partition to read
  * @param {KafkaConsumer~readCallback} cb - Callback to return when work is done.
  *//**

Original file line number	Diff line number	Diff line change
`@@ -371,7 +371,7 @@ KafkaConsumer.prototype.unsubscribe = function() {`
`371`	`371`	`* consumer can be subscribed to multiple topics.`
`372`	`372`	`*`
`373`	`373`	`* @param {number} size - Number of messages to read`
`374`		`- * @param {number} topic - Name of topic to read`
	`374`	`+ * @param {string} topic - Name of topic to read`
`375`	`375`	`* @param {number} partition - Identifier of partition to read`
`376`	`376`	`* @param {KafkaConsumer~readCallback} cb - Callback to return when work is done.`
`377`	`377`	`//*`