From c741c5342e8fbf682d6b2811ecde4f1b0491a655 Mon Sep 17 00:00:00 2001
From: Dana Powers <dana.powers@gmail.com>
Date: Fri, 3 Mar 2017 16:53:13 -0800
Subject: Include the node id in BrokerConnection __repr__ (#1009)

---
 kafka/conn.py | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

(limited to 'kafka')

diff --git a/kafka/conn.py b/kafka/conn.py
index 01b8c67..8f4fefe 100644
--- 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):
-- 
cgit v1.2.1