diff --git a/lib/poseidon/partition_consumer.rb b/lib/poseidon/partition_consumer.rb
index d8abfd1..e90bd03 100644
--- a/lib/poseidon/partition_consumer.rb
+++ b/lib/poseidon/partition_consumer.rb
@@ -137,6 +137,13 @@ def next_offset
       @offset
     end
 
+    # Set the offset (useful for seeking after initializion).
+    #
+    # @api public
+    def set_offset(offset)
+      @offset = offset
+    end
+
     # Close the connection to the kafka broker
     #
     # @return [Nil]