From cf584a35efbee05a1b020e8588f24c8d91efd431 Mon Sep 17 00:00:00 2001 From: chrislu Date: Sat, 13 Sep 2025 19:40:17 -0700 Subject: [PATCH] Update server.go --- weed/mq/kafka/gateway/server.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/weed/mq/kafka/gateway/server.go b/weed/mq/kafka/gateway/server.go index 17de7494b..069c19929 100644 --- a/weed/mq/kafka/gateway/server.go +++ b/weed/mq/kafka/gateway/server.go @@ -151,7 +151,9 @@ func (s *Server) Addr() string { if s.ln == nil { return "" } - return s.ln.Addr().String() + // Normalize to an address reachable by clients + host, port := s.GetListenerAddr() + return net.JoinHostPort(host, strconv.Itoa(port)) } // GetHandler returns the protocol handler (for testing)