diff options
| author | Taras <voyn1991@gmail.com> | 2017-10-11 20:02:18 +0300 |
|---|---|---|
| committer | Taras <voyn1991@gmail.com> | 2017-10-12 11:10:44 +0300 |
| commit | e992fbfad926486766ff7b63a499f9cf29984fec (patch) | |
| tree | 5d0ede2b60c84d06cecc9e9c2a1ee914d64f4bef /kafka | |
| parent | 0557983b2ae05adc2f1076d5e670d693c8327ab9 (diff) | |
| download | kafka-python-e992fbfad926486766ff7b63a499f9cf29984fec.tar.gz | |
Fix tests and rebase problems
Diffstat (limited to 'kafka')
| -rw-r--r-- | kafka/consumer/fetcher.py | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/kafka/consumer/fetcher.py b/kafka/consumer/fetcher.py index 493c1ff..dd90c2e 100644 --- a/kafka/consumer/fetcher.py +++ b/kafka/consumer/fetcher.py @@ -728,7 +728,6 @@ class Fetcher(six.Iterator): def _parse_fetched_data(self, completed_fetch): tp = completed_fetch.topic_partition - partition = completed_fetch.partition_data fetch_offset = completed_fetch.fetched_offset num_bytes = 0 records_count = 0 @@ -736,7 +735,6 @@ class Fetcher(six.Iterator): error_code, highwater = completed_fetch.partition_data[:2] error_type = Errors.for_code(error_code) - records = MemoryRecords(partition_data[-1]) try: if not self._subscriptions.is_fetchable(tp): @@ -760,6 +758,7 @@ class Fetcher(six.Iterator): position) return None + records = MemoryRecords(completed_fetch.partition_data[-1]) if records.has_next(): log.debug("Adding fetched record for partition %s with" " offset %d to buffered record list", tp, |