Skip to content

Commit

Permalink
Merge pull request #189 from Mickael-van-der-Beek/typo
Browse files Browse the repository at this point in the history
Typo in error message
  • Loading branch information
haio committed Apr 2, 2015
2 parents 0271c8f + 2edaecd commit 9cf6501
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions lib/client.js
Original file line number Diff line number Diff line change
Expand Up @@ -249,12 +249,12 @@ Client.prototype.createTopics = function (topics, isAsync, cb) {
function attemptCreateTopics (topics, cb) {
var operation = retry.operation({ minTimeout: 200, maxTimeout: 2000 });
operation.attempt(function(currentAttempt) {
debug('craete topics currentAttempt', currentAttempt);
debug('create topics currentAttempt', currentAttempt);
self.loadMetadataForTopics(topics, function (err, resp) {
if (resp) {
var topicMetadata = resp[1].metadata;
var created = Object.keys(topicMetadata).length === topics.length;
if (!created) err = new Error('Topic creation pendding');
if (!created) err = new Error('Topic creation pending');
}
if (operation.retry(err)) {
return;
Expand All @@ -267,7 +267,7 @@ Client.prototype.createTopics = function (topics, isAsync, cb) {

if (!topicsNotExists.length) return cb(null, 'All created');

debug('craete topic by sending metadata request');
debug('create topic by sending metadata request');
attemptCreateTopics(topicsNotExists, cb);
});
};
Expand Down

0 comments on commit 9cf6501

Please sign in to comment.