Update param in warning (#878)

In Kafka 9, advertised.host.name was renamed to advertised.listeners
This commit is contained in:
Dana Powers
2016-11-14 11:14:37 -08:00
committed by GitHub

View File

@@ -221,8 +221,8 @@ class BrokerConnection(object):
socket.SOCK_STREAM)
except socket.gaierror as ex:
raise socket.gaierror('getaddrinfo failed for {0}:{1}, '
'exception was {2}. Is your advertised.host.name correct'
' and resolvable?'.format(
'exception was {2}. Is your advertised.listeners (called'
'advertised.host.name before Kafka 9) correct and resolvable?'.format(
self.host, self.port, ex
))
self._gai_index = 0