From fd3927c0d41d59c53fc31f3aa2078fef3e706199 Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Sun, 17 Aug 2014 16:05:03 -0700 Subject: Call _raise_connection_error in KafkaConnection.reinit() if socket connection fails --- kafka/conn.py | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) (limited to 'kafka/conn.py') 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() -- cgit v1.2.1