From 13150a61510c07643c8ee5ff9dd61deffbbe8901 Mon Sep 17 00:00:00 2001 From: Jeff Widman Date: Fri, 11 Nov 2016 17:55:43 -0800 Subject: Update param in warning In Kafka 9, advertised.host.name was renamed to advertised.listeners --- kafka/conn.py | 4 ++-- 1 file 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 -- cgit v1.2.1