diff options
Diffstat (limited to 'kafka/consumer/base.py')
| -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 |