From 443d9b6751d4ce5984b90dfb1dbac74f523d563f Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Sun, 29 Sep 2019 00:01:02 -0700 Subject: Do not use wakeup when sending fetch requests from consumer --- kafka/consumer/fetcher.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'kafka') diff --git a/kafka/consumer/fetcher.py b/kafka/consumer/fetcher.py index 17c818f..1c8ac51 100644 --- a/kafka/consumer/fetcher.py +++ b/kafka/consumer/fetcher.py @@ -123,7 +123,7 @@ class Fetcher(six.Iterator): for node_id, request in six.iteritems(self._create_fetch_requests()): if self._client.ready(node_id): log.debug("Sending FetchRequest to node %s", node_id) - future = self._client.send(node_id, request) + future = self._client.send(node_id, request, wakeup=False) future.add_callback(self._handle_fetch_response, request, time.time()) future.add_errback(log.error, 'Fetch to node %s failed: %s', node_id) futures.append(future) -- cgit v1.2.1