From fdec16dc45c6e83d53538478282a00ab428b113c Mon Sep 17 00:00:00 2001
From: Dana Powers <dana.powers@rd.io>
Date: Sun, 5 Apr 2015 18:32:23 -0700
Subject: [PATCH] Add debug logging for all broker-aware requests/responses

---
 kafka/client.py | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/kafka/client.py b/kafka/client.py
index 93eeb52..08d74d7 100644
--- a/kafka/client.py
+++ b/kafka/client.py
@@ -150,6 +150,8 @@ class KafkaClient(object):
         List of response objects in the same order as the supplied payloads
         """
 
+        log.debug("Sending Payloads: %s" % payloads)
+
         # Group the requests by topic+partition
         brokers_for_payloads = []
         payloads_by_broker = collections.defaultdict(list)
@@ -220,6 +222,7 @@ class KafkaClient(object):
         # Return responses in the same order as provided
         responses_by_payload = [responses_by_broker[broker].pop(0)
                                 for broker in brokers_for_payloads]
+        log.debug('Responses: %s' % responses_by_payload)
         return responses_by_payload
 
     def __repr__(self):