summaryrefslogtreecommitdiff
path: root/kafka/client.py
diff options
context:
space:
mode:
Diffstat (limited to 'kafka/client.py')
-rw-r--r--kafka/client.py2
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/client.py b/kafka/client.py
index e66190d..02f438a 100644
--- a/kafka/client.py
+++ b/kafka/client.py
@@ -473,7 +473,7 @@ class KafkaClient(object):
resp = self.send_metadata_request(topics)
log.debug('Updating broker metadata: %s', resp.brokers)
- log.debug('Updating topic metadata: %s', resp.topics)
+ log.debug('Updating topic metadata: %s', [topic for _, topic, _ in resp.topics])
self.brokers = dict([(nodeId, BrokerMetadata(nodeId, host, port))
for nodeId, host, port in resp.brokers])