Class Endpoint

java.lang.Object
org.apache.kafka.common.Endpoint

@Evolving
public class Endpoint
extends 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