From efc03d083d323e35a2d32bcbdbccc053f737836e Mon Sep 17 00:00:00 2001 From: Taras Voinarovskiy Date: Mon, 31 Jul 2017 14:33:22 +0000 Subject: Fix test for older brokers --- kafka/consumer/fetcher.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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. " -- cgit v1.2.1