From 9268476ba8d683935f445dc0bd4b371c1a09484c Mon Sep 17 00:00:00 2001
From: Emmett Butler <emmett.butler321@gmail.com>
Date: Thu, 8 Mar 2018 10:08:59 -0800
Subject: [PATCH] add param to rdkafka simpleconsumer

---
 pykafka/rdkafka/simple_consumer.py | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

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