lib/deimos/utils/inline_consumer.rb in deimos-ruby-1.8.1.pre.beta9 vs lib/deimos/utils/inline_consumer.rb in deimos-ruby-1.8.2.pre.beta1

@@ -17,10 +17,10 @@
         begin
           last_offset = @kafka_client.last_offset_for(topic, 0)
           offset = last_offset - num_messages
           if offset.positive?
             Deimos.config.logger.info("Seeking to #{offset}")
-            @consumer.seek(topic, 0, offset)
+            @consumer.seek(topic, 1, offset)
           end
         rescue StandardError => e
           "Could not seek to offset: #{e.message}"
         end