diff --git a/CHANGELOG.md b/CHANGELOG.md new file mode 100644 index 00000000..d0b592ed --- /dev/null +++ b/CHANGELOG.md @@ -0,0 +1,5 @@ +# kafka-node CHANGELOG + +## Version NEXT (Unreleased) + +- Fix #169: When paused why try to fetch every 1000 ms? \ No newline at end of file diff --git a/lib/highLevelConsumer.js b/lib/highLevelConsumer.js index ee5796e0..38152b66 100644 --- a/lib/highLevelConsumer.js +++ b/lib/highLevelConsumer.js @@ -242,11 +242,6 @@ HighLevelConsumer.prototype.connect = function () { self.fetch(); }); } - else { - setTimeout(function () { - self.fetch(); - }, 1000); - } }); }