We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent d5c9a11 commit 6326e18Copy full SHA for 6326e18
kafka/client.py
@@ -320,8 +320,8 @@ def load_metadata_for_topics(self, *topics):
320
321
resp = self.send_metadata_request(topics)
322
323
- log.debug("Broker metadata: %s", resp.brokers)
324
- log.debug("Topic metadata: %s", resp.topics)
+ log.debug("Received new broker metadata: %s", resp.brokers)
+ log.debug("Received new topic metadata: %s", resp.topics)
325
326
self.brokers = dict([(broker.nodeId, broker)
327
for broker in resp.brokers])
0 commit comments