Add offset parameter to Consumer class which allows user to consume f…

…rom a previously saved spot
agoragames · Jan 22, 2013 · 91c941a · 91c941a
1 parent 0d5af6b
commit 91c941a
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/kafka/consumer.py b/kafka/consumer.py
@@ -13,7 +13,7 @@ class Consumer(kafka.io.IO):
   # seconds.
   DEFAULT_POLLING_INTERVAL = 2
 
-  def __init__(self, topic, partition=0, host='localhost', port=9092):
+  def __init__(self, topic, partition=0, offset=0, host='localhost', port=9092):
     kafka.io.IO.__init__(self, host, port)
 
     #: The topic queue to consume.
@@ -23,7 +23,7 @@ def __init__(self, topic, partition=0, host='localhost', port=9092):
     self.partition    = partition
 
     #: Offset in the Kafka queue in bytes?
-    self.offset       = 0
+    self.offset       = offset
 
     #: Maximum message size to consume.
     self.max_size     = self.MAX_SIZE