From 39f0e50b9441609e9dce4e60a1ab2c3f16680476 Mon Sep 17 00:00:00 2001 From: Taras Voinarovskiy Date: Sun, 30 Jul 2017 15:42:27 +0000 Subject: Added basic support for offsets_for_times API. Still needs to group by nodes and send in parallel. --- kafka/conn.py | 1 + 1 file changed, 1 insertion(+) (limited to 'kafka/conn.py') diff --git a/kafka/conn.py b/kafka/conn.py index ac8bb3d..d042300 100644 --- a/kafka/conn.py +++ b/kafka/conn.py @@ -19,6 +19,7 @@ from kafka.protocol.api import RequestHeader from kafka.protocol.admin import SaslHandShakeRequest from kafka.protocol.commit import GroupCoordinatorResponse, OffsetFetchRequest from kafka.protocol.metadata import MetadataRequest +from kafka.protocol.fetch import FetchRequest from kafka.protocol.types import Int32 from kafka.version import __version__ -- cgit v1.2.1 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