Skip to content

Commit 6467a53

Browse files
committed
include client_id in BrokerConnection __str__ output
1 parent d7e3a60 commit 6467a53

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

kafka/conn.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1315,8 +1315,8 @@ def reset_override_configs():
13151315
return version
13161316

13171317
def __str__(self):
1318-
return "<BrokerConnection node_id=%s host=%s:%d %s [%s %s]>" % (
1319-
self.node_id, self.host, self.port, self.state,
1318+
return "<BrokerConnection client_id=%s, node_id=%s host=%s:%d %s [%s %s]>" % (
1319+
self.config['client_id'], self.node_id, self.host, self.port, self.state,
13201320
AFI_NAMES[self._sock_afi], self._sock_addr)
13211321

13221322

0 commit comments

Comments
 (0)