Derive all api classes from Request / Response base classesrequest_response_classes

1 files changed, 2 insertions, 6 deletions

diff --git a/kafka/client.py b/kafka/client.py
index 1f7c23b..c233ea6 100644
--- a/kafka/client.py
+++ b/kafka/client.py
@@ -257,18 +257,14 @@ class SimpleClient(object):
                 continue
 
             request = encoder_fn(payloads=broker_payloads)
-            # decoder_fn=None signal that the server is expected to not
-            # send a response.  This probably only applies to
-            # ProduceRequest w/ acks = 0
-            expect_response = (decoder_fn is not None)
-            future = conn.send(request, expect_response=expect_response)
+            future = conn.send(request)
 
             if future.failed():
                 refresh_metadata = True
                 failed_payloads(broker_payloads)
                 continue
 
-            if not expect_response:
+            if not request.expect_response():
                 for payload in broker_payloads:
                     topic_partition = (str(payload.topic), payload.partition)
                     responses[topic_partition] = None