openstack/deb-python-kafka
Code Issues Proposed changes

KafkaClient log new broker and topic metadata received as INFO

Browse Source
This commit is contained in:
Dana Powers
2015-06-09 21:58:19 -07:00
parent d6585483e0
commit 7b2f98f5ec
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
kafka/client.py
View File

@@ -349,8 +349,8 @@ class KafkaClient(object):
resp = self.send_metadata_request(topics)
log.debug('Received new broker metadata: %s', resp.brokers)
log.debug('Received new topic metadata: %s', resp.topics)
log.info('Updating broker metadata: %s', resp.brokers)
log.info('Updating topic metadata: %s', resp.topics)
self.brokers = dict([(broker.nodeId, broker)
for broker in resp.brokers])