From 443d9b6751d4ce5984b90dfb1dbac74f523d563f Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Sun, 29 Sep 2019 00:01:02 -0700 Subject: [PATCH] Do not use wakeup when sending fetch requests from consumer --- kafka/consumer/fetcher.py | 2 +- test/test_fetcher.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/kafka/consumer/fetcher.py b/kafka/consumer/fetcher.py index 17c818f89..1c8ac51c8 100644 --- a/kafka/consumer/fetcher.py +++ b/kafka/consumer/fetcher.py @@ -123,7 +123,7 @@ def send_fetches(self): 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) diff --git a/test/test_fetcher.py b/test/test_fetcher.py index e37a70db5..a3eea09e4 100644 --- a/test/test_fetcher.py +++ b/test/test_fetcher.py @@ -81,7 +81,7 @@ def test_send_fetches(fetcher, topic, mocker): ret = fetcher.send_fetches() for node, request in enumerate(fetch_requests): - fetcher._client.send.assert_any_call(node, request) + fetcher._client.send.assert_any_call(node, request, wakeup=False) assert len(ret) == len(fetch_requests)