diff options
| author | James Brown <jbrown@easypost.com> | 2016-04-11 16:52:35 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2016-04-24 16:20:22 -0700 |
| commit | 434802dfa17f8c9d6b17b02d12bf0f7bee6240cd (patch) | |
| tree | 9eced0688e60bb9f16f28aa6a99676be2bc4e54d /test/test_client.py | |
| parent | a12be0af80a1c0903eb92566e75a63bcec988806 (diff) | |
| download | kafka-python-434802dfa17f8c9d6b17b02d12bf0f7bee6240cd.tar.gz | |
More thorough IPv6 support that uses getaddrinfo to resolve names
Fixes #641
Diffstat (limited to 'test/test_client.py')
| -rw-r--r-- | test/test_client.py | 9 |
1 files changed, 6 insertions, 3 deletions
diff --git a/test/test_client.py b/test/test_client.py index 38235fd..4b5a3a8 100644 --- a/test/test_client.py +++ b/test/test_client.py @@ -38,7 +38,8 @@ class TestSimpleClient(unittest.TestCase): client = SimpleClient(hosts=['kafka01:9092', 'kafka02:9092', 'kafka03:9092']) self.assertEqual( - sorted([('kafka01', 9092, socket.AF_INET), ('kafka02', 9092, socket.AF_INET), ('kafka03', 9092, socket.AF_INET)]), + sorted([('kafka01', 9092, socket.AF_UNSPEC), ('kafka02', 9092, socket.AF_UNSPEC), + ('kafka03', 9092, socket.AF_UNSPEC)]), sorted(client.hosts)) def test_init_with_csv(self): @@ -46,7 +47,8 @@ class TestSimpleClient(unittest.TestCase): client = SimpleClient(hosts='kafka01:9092,kafka02:9092,kafka03:9092') self.assertEqual( - sorted([('kafka01', 9092, socket.AF_INET), ('kafka02', 9092, socket.AF_INET), ('kafka03', 9092, socket.AF_INET)]), + sorted([('kafka01', 9092, socket.AF_UNSPEC), ('kafka02', 9092, socket.AF_UNSPEC), + ('kafka03', 9092, socket.AF_UNSPEC)]), sorted(client.hosts)) def test_init_with_unicode_csv(self): @@ -54,7 +56,8 @@ class TestSimpleClient(unittest.TestCase): client = SimpleClient(hosts=u'kafka01:9092,kafka02:9092,kafka03:9092') self.assertEqual( - sorted([('kafka01', 9092, socket.AF_INET), ('kafka02', 9092, socket.AF_INET), ('kafka03', 9092, socket.AF_INET)]), + sorted([('kafka01', 9092, socket.AF_UNSPEC), ('kafka02', 9092, socket.AF_UNSPEC), + ('kafka03', 9092, socket.AF_UNSPEC)]), sorted(client.hosts)) @patch.object(SimpleClient, '_get_conn') |