Skip to content

Commit c277ac8

Browse files
committed
Fix test for older brokers
1 parent 064550f commit c277ac8

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

kafka/consumer/fetcher.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -694,7 +694,7 @@ def _handle_offset_response(self, future, response):
694694
if error_type is Errors.NoError:
695695
if response.API_VERSION == 0:
696696
offsets = partition_info[2]
697-
assert len(offsets) > 1, 'Expected OffsetResponse with one offset'
697+
assert len(offsets) <= 1, 'Expected OffsetResponse with one offset'
698698
if offsets:
699699
offset = offsets[0]
700700
log.debug("Handling v0 ListOffsetResponse response for %s. "

0 commit comments

Comments
 (0)