Fix #170: In case of offsetOutOfRange, the consumer should be paused.

SOHU-Co · Mar 6, 2015 · d923143 · d923143
1 parent 0738f4f
commit d923143
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -2,4 +2,5 @@
 
 ## Version NEXT (Unreleased)
 
-- Fix #169: When paused why try to fetch every 1000 ms?
+- Fix #170: In case of `offsetOutOfRange`, the consumer should be paused.
+- Fix #169: When paused why try to fetch every 1000 ms?
diff --git a/lib/highLevelConsumer.js b/lib/highLevelConsumer.js
@@ -220,6 +220,7 @@ HighLevelConsumer.prototype.connect = function () {
     });
 
     this.on('offsetOutOfRange', function (topic) {
+        self.pause();
         topic.maxNum = self.options.maxNumSegments;
         topic.metadata = 'm';
         topic.time = Date.now();
@@ -229,6 +230,7 @@ HighLevelConsumer.prototype.connect = function () {
                 var min = Math.min.apply(null, offsets[topic.topic][topic.partition]);
                 // set minimal offset
                 self.setOffset(topic.topic, topic.partition, min);
+                self.resume();
             }
         });
     });