You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
A reachable bracketed IPv6 endpoint fails before connection validation because splitting on colons loses its host and port. CommonUtil.telnetOrPing throws IllegalArgumentException; the existing KafkaClusterSimpleInfo.validate bean uses that helper and also fails.
Expected: reachable bracketed IPv6 endpoints pass, while IPv4, optional chroot, fallback and malformed-port rejection remain supported.
Open a loopback ServerSocket on ::1 with an ephemeral port p.
Call CommonUtil.telnetOrPing("[::1]:" + p). The current split attempts to parse an empty token as the port and throws before connecting.
Set the same endpoint as brokerList on KafkaClusterSimpleInfo and call validate; it also fails.
Repeat with /service appended to the endpoint to exercise the optional chroot.
Relevant log output
Anything else
Tests exercise real IPv4/IPv6 ServerSockets and the production helper/bean. Four of six initial cases fail on the base. Seven final cases pass, including the review-discovered empty-port regression; all 15 reactor modules compile and Spotless/Checkstyle pass. No deployed Kafka registration flow was exercised. A tested fix is ready in hutiefang76/amoro branch fix/kafka-ipv6-address-validation.
Activity