We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 6447fdb commit 149d7abCopy full SHA for 149d7ab
kafka/conn.py
@@ -233,11 +233,13 @@ def connect(self):
233
socket.AF_UNSPEC,
234
socket.SOCK_STREAM)
235
except socket.gaierror as ex:
236
- raise socket.gaierror('getaddrinfo failed for {0}:{1}, '
237
- 'exception was {2}. Is your advertised.host.name correct'
238
- ' and resolvable?'.format(
239
- self.host, self.port, ex
240
- ))
+ 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(
241
+ self.host, self.port, ex))
242
+ self._gai = []
243
self._gai_index = 0
244
else:
245
# if self._gai already exists, then we should try the next
0 commit comments