diff --git a/lib/consumerGroup.js b/lib/consumerGroup.js index 5b7d9c74..aa5b3c39 100644 --- a/lib/consumerGroup.js +++ b/lib/consumerGroup.js @@ -318,7 +318,8 @@ ConsumerGroup.prototype.scheduleTopicPartitionCheck = function () { }; ConsumerGroup.prototype._checkTopicPartitionChange = function (callback) { - this.client.loadMetadataForTopics(this.topics, (error, metadataResponse) => { + const topics = Object.keys(this.topicPartitionLength); + this.client.loadMetadataForTopics(topics, (error, metadataResponse) => { if (error) { return callback(error); }