Package org.apache.kafka.common

Class Endpoint

java.lang.Object
org.apache.kafka.common.Endpoint
@Evolvingpublic class Endpointextends Object
Represents a broker endpoint.

  • Constructor Details

  • Method Details

    • listenerName

      public Optional<String> 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

      public SecurityProtocol securityProtocol()
      Returns the security protocol of this endpoint.

    • host

      public String host()
      Returns advertised host name of this endpoint.

    • port

      public int port()
      Returns the port to which the listener is bound.

    • equals

      public boolean equals(Object o)
      Overrides:
      equals in class Object

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object

    • toString

      public String toString()
      Overrides:
      toString in class Object