diff options
| author | Dana Powers <dana.powers@rd.io> | 2014-09-14 23:37:32 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2014-12-15 12:42:55 -0800 |
| commit | 67aa1a1c041d03a8139aac7081500ddd55665c46 (patch) | |
| tree | 5bb8306ad12f3bac804564acabc8a77e0403fee2 | |
| parent | d5ec0a60212fb37f77f48d9ed757135364d6aed5 (diff) | |
| download | kafka-python-67aa1a1c041d03a8139aac7081500ddd55665c46.tar.gz | |
_should_auto_commit is private
| -rw-r--r-- | kafka/consumer/new.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/kafka/consumer/new.py b/kafka/consumer/new.py index edf7843..e1273ea 100644 --- a/kafka/consumer/new.py +++ b/kafka/consumer/new.py @@ -172,7 +172,7 @@ class KafkaConsumer(object): self._msg_iter = self.fetch_messages() # Check for auto-commit - if self.should_auto_commit(): + if self._should_auto_commit(): self.commit() try: @@ -220,7 +220,7 @@ class KafkaConsumer(object): self._offsets.task_done[topic_partition] = offset - def should_auto_commit(self): + def _should_auto_commit(self): if not self._config['auto_commit_enable']: return False |