diff --git a/lib/poseidon/partition_consumer.rb b/lib/poseidon/partition_consumer.rb
index d90a64c..e585582 100644
--- a/lib/poseidon/partition_consumer.rb
+++ b/lib/poseidon/partition_consumer.rb
@@ -112,8 +112,7 @@ def fetch(options = {})
       partition_response = topic_response.partition_fetch_responses.first
 
       unless partition_response.error == Errors::NO_ERROR_CODE
-        if @offset < 0 &&
-          Errors::ERROR_CODES[partition_response.error] == Errors::OffsetOutOfRange
+        if Errors::ERROR_CODES[partition_response.error] == Errors::OffsetOutOfRange
           @offset = :earliest_offset
           return fetch(options)
         end