openstack/deb-python-kafka
Code Issues Proposed changes

Fix bug in _initiate_connect preventing reconnect to 'bootstrap'

Browse Source
This commit is contained in:
Dana Powers
2016-01-03 15:45:18 -08:00
parent 995ea64b8f
commit 4dc1fbab30
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
kafka/client_async.py
View File

@@ -131,10 +131,10 @@ class KafkaClient(object):
def _initiate_connect(self, node_id):
"""Initiate a connection to the given node (must be in metadata)"""
broker = self.cluster.broker_metadata(node_id)
assert broker, 'Broker id %s not in current metadata' % node_id
if node_id not in self._conns:
broker = self.cluster.broker_metadata(node_id)
assert broker, 'Broker id %s not in current metadata' % node_id
log.debug("Initiating connection to node %s at %s:%s",
node_id, broker.host, broker.port)
self._conns[node_id] = BrokerConnection(broker.host, broker.port,