diff options
| author | Dana Powers <dana.powers@gmail.com> | 2016-11-14 11:14:37 -0800 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2016-11-14 11:14:37 -0800 |
| commit | 43e0c38bf350eb38d3356de88f98308f7d408572 (patch) | |
| tree | 5b64638196ad7af39a7e8fca97787fd786518398 | |
| parent | eb6801da35c14f7c28d9d7f441f301a146e4d0db (diff) | |
| parent | 13150a61510c07643c8ee5ff9dd61deffbbe8901 (diff) | |
| download | kafka-python-43e0c38bf350eb38d3356de88f98308f7d408572.tar.gz | |
Update param in warning (#878)
In Kafka 9, advertised.host.name was renamed to advertised.listeners
| -rw-r--r-- | kafka/conn.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/kafka/conn.py b/kafka/conn.py index 9f5b3f0..5775af8 100644 --- a/kafka/conn.py +++ b/kafka/conn.py @@ -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 |