diff options
| author | Dana Powers <dana.powers@rd.io> | 2015-04-05 18:32:23 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2015-04-06 10:42:36 -0700 |
| commit | fdec16dc45c6e83d53538478282a00ab428b113c (patch) | |
| tree | fc741f42aed93854f33c682d4270f1d81e5735d0 /kafka/client.py | |
| parent | 5cc051353eff67713bd4885372e1aee12fab22f0 (diff) | |
| download | kafka-python-fdec16dc45c6e83d53538478282a00ab428b113c.tar.gz | |
Add debug logging for all broker-aware requests/responses
Diffstat (limited to 'kafka/client.py')
| -rw-r--r-- | kafka/client.py | 3 |
1 files changed, 3 insertions, 0 deletions
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): |