add param to rdkafka simpleconsumer

Parsely · Mar 8, 2018 · 9268476 · 9268476
1 parent c198907
commit 9268476
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/pykafka/rdkafka/simple_consumer.py b/pykafka/rdkafka/simple_consumer.py
@@ -55,7 +55,8 @@ def __init__(self,
                  compacted_topic=False,
                  generation_id=-1,
                  consumer_id=b'',
-                 deserializer=None):
+                 deserializer=None,
+                 reset_offset_on_fetch=True):
         callargs = {k: v for k, v in vars().items()
                          if k not in ("self", "__class__")}
         self._rdk_consumer = None