Add more debug/trace statements to sender loop

dpkp · dpkp · commit b60df8d1743b · 2016-02-02T07:57:04.000-08:00
diff --git a/kafka/producer/sender.py b/kafka/producer/sender.py
@@ -97,13 +97,15 @@ def run_once(self):
         # if there are any partitions whose leaders are not known yet, force
         # metadata update
         if unknown_leaders_exist:
+            log.debug('Unknown leaders exist, requesting metadata update')
             with self._lock:
                 self._metadata.request_update()
 
         # remove any nodes we aren't ready to send to
         not_ready_timeout = 999999999
         for node in list(ready_nodes):
             if not self._client.ready(node):
+                log.debug('Node %s not ready; delaying produce of accumulated batch', node)
                 ready_nodes.remove(node)
                 not_ready_timeout = min(not_ready_timeout,
                                         self._client.connection_delay(node))
