From 1f69f8f5b875d1b263663bdf6aa2fc17faa4a3e5 Mon Sep 17 00:00:00 2001 From: Taras Voinarovskiy Date: Sat, 5 Aug 2017 17:19:54 +0000 Subject: Added `beginning_offsets` and `end_offsets` API's and fixed @jeffwidman review issues --- kafka/conn.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'kafka/conn.py') diff --git a/kafka/conn.py b/kafka/conn.py index d042300..61d63bf 100644 --- a/kafka/conn.py +++ b/kafka/conn.py @@ -887,7 +887,7 @@ class BrokerConnection(object): def _infer_broker_version_from_api_versions(self, api_versions): # The logic here is to check the list of supported request versions - # in descending order. As soon as we find one that works, return it + # in reverse order. As soon as we find one that works, return it test_cases = [ # format (, ) ((0, 11, 0), MetadataRequest[4]), -- cgit v1.2.1