diff options
| author | Dana Powers <dana.powers@gmail.com> | 2018-02-05 14:02:24 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2018-02-05 14:02:24 -0800 |
| commit | c6b54036af4aebaca545898fe0d8100a15f93ee8 (patch) | |
| tree | 8f834926048f56755bbd146b3e97a1370aa6afb4 /kafka/consumer | |
| parent | 619895d1216cfc3b5da4270d3869cd31b7b55a14 (diff) | |
| download | kafka-python-fetch_partition_compressed_offset.tar.gz | |
Fix for PartitionRecords has no attribute message_idx; add testfetch_partition_compressed_offset
Diffstat (limited to 'kafka/consumer')
| -rw-r--r-- | kafka/consumer/fetcher.py | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/kafka/consumer/fetcher.py b/kafka/consumer/fetcher.py index 6597448..c9bbb97 100644 --- a/kafka/consumer/fetcher.py +++ b/kafka/consumer/fetcher.py @@ -846,6 +846,10 @@ class Fetcher(six.Iterator): for i, msg in enumerate(messages): if msg.offset == fetch_offset: self.message_idx = i + break + else: + self.message_idx = 0 + self.messages = None # For truthiness evaluation we need to define __len__ or __nonzero__ def __len__(self): |