diff --git a/lib/baseClient.js b/lib/baseClient.js index 31c7f76a..aeb97038 100644 --- a/lib/baseClient.js +++ b/lib/baseClient.js @@ -253,7 +253,7 @@ Client.prototype.createTopics = function (topics, isAsync, cb) { if (typeof isAsync === 'function' && typeof cb === 'undefined') { cb = isAsync; - isAsync = true; + isAsync = false; } try { diff --git a/test/test.offset.js b/test/test.offset.js index 98aaec4f..f77f6f97 100644 --- a/test/test.offset.js +++ b/test/test.offset.js @@ -14,7 +14,7 @@ describe('Offset', function () { client = new Client(); producer = new Producer(client); producer.on('ready', function () { - producer.createTopics(['_exist_topic_3_test'], true, function (err) { + producer.createTopics(['_exist_topic_3_test'], false, function (err) { done(err); }); });