diff --git a/pykafka/rdkafka/simple_consumer.py b/pykafka/rdkafka/simple_consumer.py
index e235061a7..d3444463d 100644
--- 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