diff --git a/lib/client.js b/lib/client.js index 9f144af3..6b42131d 100644 --- a/lib/client.js +++ b/lib/client.js @@ -393,7 +393,7 @@ Client.prototype.createTopics = function (topics, isAsync, cb) { const left = _.difference(topics, kafkaTopics); if (left.length === 0) { logger.debug(`Topics created ${kafkaTopics}`); - return cb(null); + return cb(null, kafkaTopics); } logger.debug(`Topics left ${left.join(', ')}`);