mdedetrich commented on code in PR #11478: URL: https://github.com/apache/kafka/pull/11478#discussion_r923366063
########## core/src/main/scala/kafka/utils/CoreUtils.scala: ########## @@ -252,16 +255,62 @@ object CoreUtils { listenerListToEndPoints(listeners, securityProtocolMap, true) } + def validateOneIsIpv4AndOtherIpv6(first: String, second: String): Boolean = + (inetAddressValidator.isValidInet4Address(first) && inetAddressValidator.isValidInet6Address(second)) || + (inetAddressValidator.isValidInet6Address(first) && inetAddressValidator.isValidInet4Address(second)) + + def checkDuplicateListenerNames(endpoints: Seq[EndPoint], listeners: String): Unit = { + val distinctListenerNames = endpoints.map(_.listenerName).distinct + require(distinctListenerNames.size == endpoints.size, s"Each listener must have a different name unless you have exactly " + + s"one listener on IPv4 and the other IPv6 on the same port, listeners: $listeners") + } + + def checkDuplicateListenerPorts(endpoints: Seq[EndPoint], listeners: String): Unit = { + val distinctPorts = endpoints.map(_.port).distinct + require(distinctPorts.size == endpoints.map(_.port).size, s"Each listener must have a different port, listeners: $listeners") + } + def listenerListToEndPoints(listeners: String, securityProtocolMap: Map[ListenerName, SecurityProtocol], requireDistinctPorts: Boolean): Seq[EndPoint] = { def validate(endPoints: Seq[EndPoint]): Unit = { - // filter port 0 for unit tests - val portsExcludingZero = endPoints.map(_.port).filter(_ != 0) - val distinctListenerNames = endPoints.map(_.listenerName).distinct - - require(distinctListenerNames.size == endPoints.size, s"Each listener must have a different name, listeners: $listeners") - if (requireDistinctPorts) { - val distinctPorts = portsExcludingZero.distinct - require(distinctPorts.size == portsExcludingZero.size, s"Each listener must have a different port, listeners: $listeners") + // Exception case, lets allow duplicate ports if the host is on IPv4 and the other is on IPv6 Review Comment: Moved it to where you suggested, let me know if it corresponds to what you had in mind. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org