Package org.apache.kafka.common
Class Endpoint
java.lang.Object
org.apache.kafka.common.Endpoint
@Evolving public class Endpoint extends Object
Represents a broker endpoint.
-
Constructor Summary
Constructors Constructor Description Endpoint(String listenerName, SecurityProtocol securityProtocol, String host, int port)
-
Method Summary
Modifier and Type Method Description boolean
equals(Object o)
int
hashCode()
String
host()
Returns advertised host name of this endpoint.Optional<String>
listenerName()
Returns the listener name of this endpoint.int
port()
Returns the port to which the listener is bound.SecurityProtocol
securityProtocol()
Returns the security protocol of this endpoint.String
toString()
-
Constructor Details
-
Endpoint
-
-
Method Details
-
listenerName
Returns the listener name of this endpoint. This is non-empty for endpoints provided to broker plugins, but may be empty when used in clients. -
securityProtocol
Returns the security protocol of this endpoint. -
host
Returns advertised host name of this endpoint. -
port
public int port()Returns the port to which the listener is bound. -
equals
-
hashCode
public int hashCode() -
toString
-