File tree Expand file tree Collapse file tree 1 file changed +7
-5
lines changed Expand file tree Collapse file tree 1 file changed +7
-5
lines changed Original file line number Diff line number Diff line change @@ -237,11 +237,13 @@ def connect(self):
237
237
socket .AF_UNSPEC ,
238
238
socket .SOCK_STREAM )
239
239
except socket .gaierror as ex :
240
- raise socket .gaierror ('getaddrinfo failed for {0}:{1}, '
241
- 'exception was {2}. Is your advertised.listeners (called'
242
- 'advertised.host.name before Kafka 9) correct and resolvable?' .format (
243
- self ._init_host , self ._init_port , ex
244
- ))
240
+ log .warning ('DNS lookup failed for {0}:{1},'
241
+ ' exception was {2}. Is your'
242
+ ' advertised.listeners (called'
243
+ ' advertised.host.name before Kafka 9)'
244
+ ' correct and resolvable?' .format (
245
+ self ._init_host , self ._init_port , ex ))
246
+ self ._gai = []
245
247
self ._gai_index = 0
246
248
else :
247
249
# if self._gai already exists, then we should try the next
You can’t perform that action at this time.
0 commit comments