diff options
author | Jeff Widman <jeff@jeffwidman.com> | 2016-11-11 17:55:43 -0800 |
---|---|---|
committer | GitHub <noreply@github.com> | 2016-11-11 17:55:43 -0800 |
commit | 13150a61510c07643c8ee5ff9dd61deffbbe8901 (patch) | |
tree | fc5107ebba3a39ea58b7bee165409d81c27ebbe2 | |
parent | 77591afa789a4752f4d385228bea980f448f6a08 (diff) | |
download | kafka-python-13150a61510c07643c8ee5ff9dd61deffbbe8901.tar.gz |
Update param in warning
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 6af0d8f..18f6ec3 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 |