Fix test for older brokers

tvoinarovskyi · tvoinarovskyi · commit efc03d083d32 · 2017-08-07T09:34:09.000Z
diff --git a/kafka/consumer/fetcher.py b/kafka/consumer/fetcher.py
@@ -701,7 +701,7 @@ def _handle_offset_response(self, future, response):
                 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. "
