summaryrefslogtreecommitdiff
path: root/kafka/conn.py
diff options
context:
space:
mode:
authorDana Powers <dana.powers@gmail.com>2017-04-10 10:06:46 -0700
committerGitHub <noreply@github.com>2017-04-10 10:06:46 -0700
commit04296994defcbf1c6dd9d1bae802af94bc11d74f (patch)
tree4df566314f7cb072b9d87034d3615db4ad17540d /kafka/conn.py
parent7c24135eaf1db95c50c5d340cd15cbfc2674c927 (diff)
downloadkafka-python-04296994defcbf1c6dd9d1bae802af94bc11d74f.tar.gz
Timeout idle connections via connections_max_idle_ms (#1068)
Diffstat (limited to 'kafka/conn.py')
-rw-r--r--kafka/conn.py6
1 files changed, 4 insertions, 2 deletions
diff --git a/kafka/conn.py b/kafka/conn.py
index d5b7c50..58ce836 100644
--- a/kafka/conn.py
+++ b/kafka/conn.py
@@ -177,6 +177,8 @@ class BrokerConnection(object):
if key in configs:
self.config[key] = configs[key]
+ self.node_id = self.config.pop('node_id')
+
if self.config['receive_buffer_bytes'] is not None:
self.config['socket_options'].append(
(socket.SOL_SOCKET, socket.SO_RCVBUF,
@@ -214,7 +216,7 @@ class BrokerConnection(object):
if self.config['metrics']:
self._sensors = BrokerConnectionMetrics(self.config['metrics'],
self.config['metric_group_prefix'],
- self.config['node_id'])
+ self.node_id)
def connect(self):
"""Attempt to connect and return ConnectionState"""
@@ -904,7 +906,7 @@ class BrokerConnection(object):
def __repr__(self):
return "<BrokerConnection node_id=%s host=%s/%s port=%d>" % (
- self.config['node_id'], self.hostname, self.host, self.port)
+ self.node_id, self.hostname, self.host, self.port)
class BrokerConnectionMetrics(object):