summaryrefslogtreecommitdiff
path: root/kafka
diff options
context:
space:
mode:
authorDana Powers <dana.powers@gmail.com>2019-09-29 00:01:02 -0700
committerDana Powers <dana.powers@gmail.com>2019-09-29 00:01:02 -0700
commit443d9b6751d4ce5984b90dfb1dbac74f523d563f (patch)
treeb064f18a259976b873ef27219a3f243bdd8b0a2c /kafka
parent89bf6a6ee51e8a54f909eae4785d04e485b91198 (diff)
downloadkafka-python-fetcher_send_no_wakeup.tar.gz
Do not use wakeup when sending fetch requests from consumerfetcher_send_no_wakeup
Diffstat (limited to 'kafka')
-rw-r--r--kafka/consumer/fetcher.py2
1 files changed, 1 insertions, 1 deletions
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)