diff options
| author | Nickolai Novik <is.infinity@yahoo.com> | 2014-12-15 01:16:50 +0200 |
|---|---|---|
| committer | Nickolai Novik <is.infinity@yahoo.com> | 2014-12-15 01:16:50 +0200 |
| commit | ae79eff49bba38611048a46f0ec380eb664c2983 (patch) | |
| tree | c457fc91ee4413447f64d9cdaad5facc9f51ddc3 /kafka | |
| parent | 3fc4dca1dba39c1416d6cc9624cbc9595276b366 (diff) | |
| download | kafka-python-ae79eff49bba38611048a46f0ec380eb664c2983.tar.gz | |
fix pending method
Diffstat (limited to 'kafka')
| -rw-r--r-- | kafka/consumer/base.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/consumer/base.py b/kafka/consumer/base.py index 506b405..2464aaf 100644 --- a/kafka/consumer/base.py +++ b/kafka/consumer/base.py @@ -164,6 +164,6 @@ class Consumer(object): partition = resp.partition pending = resp.offsets[0] offset = self.offsets[partition] - total += pending - offset - (1 if offset > 0 else 0) + total += pending - offset return total |