diff options
| author | Dana Powers <dana.powers@rd.io> | 2015-03-29 17:24:56 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2015-03-30 15:02:44 -0700 |
| commit | b6d032cc3f1b53a6d5b395f9b14de62f547c8f1c (patch) | |
| tree | 2111012432d8f23991068d3c6ea438da8fe10d2e /kafka/consumer/simple.py | |
| parent | 32dd817aac4130a019339afac7ef52f2b9b7acd4 (diff) | |
| download | kafka-python-b6d032cc3f1b53a6d5b395f9b14de62f547c8f1c.tar.gz | |
Fetch previously committed offsets in base consumer class so long as
a group is configured (but document that group must be None for old
servers). This fixes multiprocessor consumer issue that prevented
access to commit offsets if auto_commit is disabled.
Also refactor fetch_last_known_offsets based on KafkaConsumer
While still setting unknown offsets to 0
Diffstat (limited to 'kafka/consumer/simple.py')
| -rw-r--r-- | kafka/consumer/simple.py | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/kafka/consumer/simple.py b/kafka/consumer/simple.py index b50de61..ae00dab 100644 --- a/kafka/consumer/simple.py +++ b/kafka/consumer/simple.py @@ -73,6 +73,8 @@ class SimpleConsumer(Consumer): Arguments: client: a connected KafkaClient group: a name for this consumer, used for offset storage and must be unique + If you are connecting to a server that does not support offset + commit/fetch (any prior to 0.8.1.1), then you *must* set this to None topic: the topic to consume Keyword Arguments: |