Include the node id in BrokerConnection __repr__ (#1009)

2017-03-03 16:53:13 -08:00
parent 46b857fbbd
commit c741c5342e
1 changed files with 2 additions and 2 deletions
--- a/kafka/conn.py
+++ b/kafka/conn.py
@@ -868,8 +868,8 @@ class BrokerConnection(object):
        return version

    def __repr__(self):
-        return "<BrokerConnection host=%s/%s port=%d>" % (self.hostname, self.host,
-                                                          self.port)
+        return "<BrokerConnection node_id=%s host=%s/%s port=%d>" % (
+            self.config['node_id'], self.hostname, self.host, self.port)


 class BrokerConnectionMetrics(object):