Use debug logging level for metadata request

This commit is contained in:
Enrico Canzonieri
2015-07-21 11:09:46 -07:00
parent adbd4ac052
commit 00ceada028

View File

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