diff options
Diffstat (limited to 'kafka/client.py')
| -rw-r--r-- | kafka/client.py | 8 |
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 |