diff options
Diffstat (limited to 'kafka/client_async.py')
| -rw-r--r-- | kafka/client_async.py | 7 |
1 files changed, 1 insertions, 6 deletions
diff --git a/kafka/client_async.py b/kafka/client_async.py index c0cdc43..2d711e4 100644 --- a/kafka/client_async.py +++ b/kafka/client_async.py @@ -464,12 +464,7 @@ class KafkaClient(object): if not self._maybe_connect(node_id): return Future().failure(Errors.NodeNotReadyError(node_id)) - # Every request gets a response, except one special case: - expect_response = True - if isinstance(request, tuple(ProduceRequest)) and request.required_acks == 0: - expect_response = False - - return self._conns[node_id].send(request, expect_response=expect_response) + return self._conns[node_id].send(request) def poll(self, timeout_ms=None, future=None, sleep=True, delayed_tasks=True): """Try to read and write to sockets. |