diff options
| -rw-r--r-- | kafka/consumer/fetcher.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/consumer/fetcher.py b/kafka/consumer/fetcher.py index 19982b1..1a3dfd5 100644 --- a/kafka/consumer/fetcher.py +++ b/kafka/consumer/fetcher.py @@ -701,7 +701,7 @@ class Fetcher(six.Iterator): if error_type is Errors.NoError: if response.API_VERSION == 0: offsets = partition_info[2] - assert len(offsets) > 1, 'Expected OffsetResponse with one offset' + assert len(offsets) <= 1, 'Expected OffsetResponse with one offset' if offsets: offset = offsets[0] log.debug("Handling v0 ListOffsetResponse response for %s. " |