diff options
| author | Dana Powers <dana.powers@gmail.com> | 2018-02-13 12:14:51 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2018-02-13 12:14:51 -0800 |
| commit | bf279eb9b545f6769cd78c62c319320999ebbb2f (patch) | |
| tree | 0e9b3e21265bcc7a437dc34b5bda3e4ed3cac728 | |
| parent | 3693740eb6d6e8c07a10d9d0cdde965751b7694b (diff) | |
| download | kafka-python-bf279eb9b545f6769cd78c62c319320999ebbb2f.tar.gz | |
destructure socket family separately to support both ipv4 / ipv6
| -rw-r--r-- | kafka/client_async.py | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/kafka/client_async.py b/kafka/client_async.py index 7ff7f52..8854ec2 100644 --- a/kafka/client_async.py +++ b/kafka/client_async.py @@ -263,7 +263,8 @@ class KafkaClient(object): # as possible. So because of that, we do dns resolution upfront, # create a new BrokerConnection for each resolved sockaddr, and # attempt only a single connect loop before moving to the next sockaddr. - for afi, _, __, ___, (host, port) in dns_lookup(*unresolved_host): + for afi, _, __, ___, family in dns_lookup(*unresolved_host): + host, port = family[:2] bootstrap = BrokerConnection(host, port, afi, state_change_callback=cb, node_id='bootstrap', |