Comparing version
{ | ||
"name": "kafkajs", | ||
"version": "1.13.0-beta.43", | ||
"version": "1.13.0-beta.44", | ||
"description": "A modern Apache Kafka client for node.js", | ||
@@ -82,5 +82,5 @@ "author": "Tulio Ornelas <ornelas.tulio@gmail.com>", | ||
"kafkajs": { | ||
"sha": "2882ef0ececb701c1eeda5b90d8458c43583cdea", | ||
"compare": "https://github.com/tulios/kafkajs/compare/v1.12.0...2882ef0ececb701c1eeda5b90d8458c43583cdea" | ||
"sha": "020ea3013007ccd0b83353c549c844dc828cca79", | ||
"compare": "https://github.com/tulios/kafkajs/compare/v1.12.0...020ea3013007ccd0b83353c549c844dc828cca79" | ||
} | ||
} |
@@ -605,3 +605,3 @@ const createRetry = require('../retry') | ||
name: topic, | ||
partitions: await cluster.findTopicPartitionMetadata(topic), | ||
partitions: cluster.findTopicPartitionMetadata(topic), | ||
})) | ||
@@ -608,0 +608,0 @@ ), |
@@ -244,3 +244,3 @@ const BrokerPool = require('./brokerPool') | ||
* @param {string} topic | ||
* @returns {Object} Example: | ||
* @returns {import("../../types").PartitionMetadata[]} Example: | ||
* [{ | ||
@@ -247,0 +247,0 @@ * isr: [2], |
523045
0.01%