public final class EndPoint
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
static java.util.Map<org.apache.kafka.common.network.ListenerName,org.apache.kafka.common.security.auth.SecurityProtocol> |
DEFAULT_SECURITY_PROTOCOL_MAP |
Constructor and Description |
---|
EndPoint(java.lang.String host,
int port,
org.apache.kafka.common.network.ListenerName listenerName,
org.apache.kafka.common.security.auth.SecurityProtocol securityProtocol) |
EndPoint(java.lang.String host,
int port,
org.apache.kafka.common.security.auth.SecurityProtocol securityProtocol) |
Modifier and Type | Method and Description |
---|---|
java.net.InetSocketAddress |
address() |
java.lang.String |
connectionString() |
boolean |
equals(java.lang.Object other) |
int |
hashCode() |
java.lang.String |
host() |
org.apache.kafka.common.network.ListenerName |
listenerName() |
static EndPoint |
parse(java.lang.String connectionString) |
static EndPoint |
parse(java.lang.String connectionString,
java.util.Map<org.apache.kafka.common.network.ListenerName,org.apache.kafka.common.security.auth.SecurityProtocol> securityProtocolMap) |
int |
port() |
java.net.InetSocketAddress |
resolvedAddress() |
org.apache.kafka.common.security.auth.SecurityProtocol |
securityProtocol() |
java.lang.String |
toString() |
public static final java.util.Map<org.apache.kafka.common.network.ListenerName,org.apache.kafka.common.security.auth.SecurityProtocol> DEFAULT_SECURITY_PROTOCOL_MAP
public EndPoint(java.lang.String host, int port, org.apache.kafka.common.security.auth.SecurityProtocol securityProtocol)
public EndPoint(java.lang.String host, int port, org.apache.kafka.common.network.ListenerName listenerName, org.apache.kafka.common.security.auth.SecurityProtocol securityProtocol)
public static EndPoint parse(java.lang.String connectionString)
public static EndPoint parse(java.lang.String connectionString, java.util.Map<org.apache.kafka.common.network.ListenerName,org.apache.kafka.common.security.auth.SecurityProtocol> securityProtocolMap)
public org.apache.kafka.common.network.ListenerName listenerName()
public org.apache.kafka.common.security.auth.SecurityProtocol securityProtocol()
public java.lang.String host()
public int port()
public boolean equals(java.lang.Object other)
equals
in class java.lang.Object
public int hashCode()
hashCode
in class java.lang.Object
public java.net.InetSocketAddress address() throws java.net.UnknownHostException
java.net.UnknownHostException
public java.net.InetSocketAddress resolvedAddress() throws java.net.UnknownHostException
java.net.UnknownHostException
public java.lang.String connectionString()
public java.lang.String toString()
toString
in class java.lang.Object