Add comment about no server response case in _send_broker_aware_request

1 files changed, 5 insertions, 0 deletions

diff --git a/kafka/client.py b/kafka/client.py
index 53b6ad0..6c6e74f 100644
--- a/kafka/client.py
+++ b/kafka/client.py
@@ -178,8 +178,13 @@ class KafkaClient(object):
             # Send the request, recv the response
             try:
                 conn.send(requestId, request)
+
+                # decoder_fn=None signal that the server  is expected to not
+                # send a response.  This probably only applies to
+                # ProduceRequest w/ acks = 0
                 if decoder_fn is None:
                     continue
+
                 try:
                     response = conn.recv(requestId)
                 except ConnectionError as e: