summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorDana Powers <dana.powers@gmail.com>2019-09-29 07:56:12 -0700
committerGitHub <noreply@github.com>2019-09-29 07:56:12 -0700
commit9de12d3f03236988a60e6cd79a50ffa5165cf735 (patch)
treeb064f18a259976b873ef27219a3f243bdd8b0a2c
parent89bf6a6ee51e8a54f909eae4785d04e485b91198 (diff)
downloadkafka-python-9de12d3f03236988a60e6cd79a50ffa5165cf735.tar.gz
Do not use wakeup when sending fetch requests from consumer (#1911)
-rw-r--r--kafka/consumer/fetcher.py2
-rw-r--r--test/test_fetcher.py2
2 files changed, 2 insertions, 2 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)
diff --git a/test/test_fetcher.py b/test/test_fetcher.py
index e37a70d..a3eea09 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)