From 2fa84a24be25ab7676bcb7d2926065388fa4782b Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Sat, 29 Apr 2017 10:15:32 -0700 Subject: [PATCH] Warn dont raise on DNS lookup failures --- kafka/conn.py | 12 +++++++----- 1 file changed, 7 insertions(+), 5 deletions(-) diff --git a/kafka/conn.py b/kafka/conn.py index 58ce8362c..12bd08df4 100644 --- a/kafka/conn.py +++ b/kafka/conn.py @@ -237,11 +237,13 @@ def connect(self): socket.AF_UNSPEC, socket.SOCK_STREAM) except socket.gaierror as ex: - raise socket.gaierror('getaddrinfo failed for {0}:{1}, ' - 'exception was {2}. Is your advertised.listeners (called' - 'advertised.host.name before Kafka 9) correct and resolvable?'.format( - self._init_host, self._init_port, ex - )) + log.warning('DNS lookup failed for {0}:{1},' + ' exception was {2}. Is your' + ' advertised.listeners (called' + ' advertised.host.name before Kafka 9)' + ' correct and resolvable?'.format( + self._init_host, self._init_port, ex)) + self._gai = [] self._gai_index = 0 else: # if self._gai already exists, then we should try the next