diff options
| -rw-r--r-- | kafka/consumer/fetcher.py | 2 | ||||
| -rw-r--r-- | 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 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) |