summaryrefslogtreecommitdiff
path: root/kafka/conn.py
diff options
context:
space:
mode:
authorDana Powers <dana.powers@rd.io>2014-08-17 16:05:03 -0700
committerDana Powers <dana.powers@rd.io>2014-08-17 16:05:03 -0700
commitfd3927c0d41d59c53fc31f3aa2078fef3e706199 (patch)
tree4d7a7eaa69801eef8ce87984985248587857b745 /kafka/conn.py
parentcea8ec3297cdc70d0c7c9a08c3c158703a4baa45 (diff)
downloadkafka-python-fd3927c0d41d59c53fc31f3aa2078fef3e706199.tar.gz
Call _raise_connection_error in KafkaConnection.reinit() if socket connection fails
Diffstat (limited to 'kafka/conn.py')
-rw-r--r--kafka/conn.py8
1 files changed, 6 insertions, 2 deletions
diff --git a/kafka/conn.py b/kafka/conn.py
index b5dafd8..d54d70a 100644
--- a/kafka/conn.py
+++ b/kafka/conn.py
@@ -149,5 +149,9 @@ class KafkaConnection(local):
Re-initialize the socket connection
"""
self.close()
- self._sock = socket.create_connection((self.host, self.port), self.timeout)
- self._dirty = False
+ try:
+ self._sock = socket.create_connection((self.host, self.port), self.timeout)
+ self._dirty = False
+ except socket.error:
+ log.exception('Unable to connect to kafka broker at %s:%d' % (self.host, self.port))
+ self._raise_connection_error()