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