From 894cfec656e44f92766775baf84cfd1d2e257901 Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Sun, 12 Mar 2017 19:57:36 -0700 Subject: Derive all api classes from Request / Response base classes --- kafka/client_async.py | 7 +------ 1 file changed, 1 insertion(+), 6 deletions(-) (limited to 'kafka/client_async.py') 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. -- cgit v1.2.1