Merge pull request #432 from ecanzonieri/lower_logging_level_metadata

Use debug logging level for metadata request
This commit is contained in:
Dana Powers
2015-08-24 10:56:32 -07:00

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])