KafkaClient: log responses by requestId for debugging

kafka/client.py

@@ -193,6 +193,8 @@ class KafkaClient(object):
                 # send a response.  This probably only applies to
                 # ProduceRequest w/ acks = 0
                 if decoder_fn is None:
+                    log.debug('Request %s does not expect a response '
+                              '(skipping conn.recv)', requestId)
                     for payload in payloads:
                         responses_by_broker[broker].append(None)
                     continue
@@ -211,6 +213,7 @@ class KafkaClient(object):
                 else:
                     for payload_response in decoder_fn(response):
                         responses_by_broker[broker].append(payload_response)
+                    log.debug('Response %s: %s', requestId, responses_by_broker[broker])
 
         # Connection errors generally mean stale metadata
         # although sometimes it means incorrect api request