fix param name

Parsely · Mar 8, 2018 · c198907 · c198907
1 parent 4cbd79e
commit c198907
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/pykafka/simpleconsumer.py b/pykafka/simpleconsumer.py
@@ -236,7 +236,7 @@ def __init__(self,
         self.partition_cycle = itertools.cycle(self._partitions.values())
 
         self._default_error_handlers = self._build_default_error_handlers()
-        self.reset_offset_on_fetch = reset_offset_on_fetch
+        self._reset_offset_on_fetch = reset_offset_on_fetch
 
         if self._auto_start:
             self.start()
@@ -623,7 +623,7 @@ def _handle_success(parts):
             parts_by_error = handle_partition_responses(
                 self._default_error_handlers,
                 response=res,
-                success_handler=_handle_success if self.reset_offsets_on_fetch else None,
+                success_handler=_handle_success if self._reset_offset_on_fetch else None,
                 partitions_by_id=self._partitions_by_id)
 
             success_responses.extend([(op.partition.id, r)