summaryrefslogtreecommitdiff
path: root/kafka/client_async.py
diff options
context:
space:
mode:
authorDana Powers <dana.powers@gmail.com>2016-08-04 12:21:40 -0700
committerDana Powers <dana.powers@gmail.com>2016-08-04 13:05:36 -0700
commit460f0784a30f303b4543763ca330cce52d6054eb (patch)
tree471f0053fe1b7a9fd5e8cece0c43b8f012dd5ad2 /kafka/client_async.py
parentaf08b54875a5ae5c14fbdeccee4ffe266bda1e00 (diff)
downloadkafka-python-460f0784a30f303b4543763ca330cce52d6054eb.tar.gz
Instrument metrics in BrokerConnection
Diffstat (limited to 'kafka/client_async.py')
-rw-r--r--kafka/client_async.py2
1 files changed, 2 insertions, 0 deletions
diff --git a/kafka/client_async.py b/kafka/client_async.py
index ff566ca..ce1d13b 100644
--- a/kafka/client_async.py
+++ b/kafka/client_async.py
@@ -222,6 +222,7 @@ class KafkaClient(object):
cb = functools.partial(self._conn_state_change, 'bootstrap')
bootstrap = BrokerConnection(host, port, afi,
state_change_callback=cb,
+ node_id='bootstrap',
**self.config)
bootstrap.connect()
while bootstrap.connecting():
@@ -313,6 +314,7 @@ class KafkaClient(object):
cb = functools.partial(self._conn_state_change, node_id)
self._conns[node_id] = BrokerConnection(host, broker.port, afi,
state_change_callback=cb,
+ node_id=node_id,
**self.config)
conn = self._conns[node_id]
if conn.connected():