openstack/oslo.messaging
Code Issues Proposed changes

Merge "kafka: Fix invalid hostaddr format for IPv6 address"

Browse Source
This commit is contained in:
Zuul 2024-03-27 12:02:40 +00:00 committed by Gerrit Code Review
commit 63f95e92c3
2 changed files with 16 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
oslo_messaging/_drivers/impl_kafka.py
View File

@ -125,7 +125,12 @@ class Connection(object):
LOG.warning("Different transport usernames detected")
if host.hostname:
self.hostaddrs.append("%s:%s" % (host.hostname, host.port))
if ':' in host.hostname:
hostaddr = "[%s]:%s" % (host.hostname, host.port)
else:
hostaddr = "%s:%s" % (host.hostname, host.port)
self.hostaddrs.append(hostaddr)
def reset(self):
"""Reset a connection so it can be used again."""

10
oslo_messaging/tests/drivers/test_impl_kafka.py
View File

@ -66,6 +66,16 @@ class TestKafkaTransportURL(test_utils.BaseTestCase):
username='stack',
password='stacksecret',
vhost='my_host'))),
('ipv4', dict(url='kafka://127.0.0.1:1234',
expected=dict(hostaddrs=['127.0.0.1:1234'],
username=None,
password=None,
vhost=None))),
('ipv6', dict(url='kafka://[::1]:1234',
expected=dict(hostaddrs=['[::1]:1234'],
username=None,
password=None,
vhost=None))),
]
def setUp(self):