openstack/deb-python-kafka
Code Issues Proposed changes

Add more debug/trace statements to sender loop

Browse Source
This commit is contained in:
Dana Powers
2016-02-02 07:57:04 -08:00
parent 22a1b6dc70
commit b60df8d174
1 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
kafka/producer/sender.py
View File

@@ -97,6 +97,7 @@ class Sender(threading.Thread):
# 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()
@@ -104,6 +105,7 @@ class Sender(threading.Thread):
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))