kafka-cluster-EndPoint.adoc

EndPoint

EndPoint is a data structure that represents an endpoint of a Kafka broker using the following properties:

• Host

• Port

• ListenerName

• SecurityProtocol

EndPoint is created when:

• Broker is created

• EndPoint utility is used to create one

• MetadataCache is requested to update a metadata

• BrokerIdZNode utility is used to encode and decode a broker metadata

EndPoint is used when:

• SocketServer is requested to create an Acceptor and addDataPlaneProcessors

connectionString Method

connectionString: String

connectionString…​FIXME

Note	connectionString is used when…​FIXME

Creating EndPoint — createEndPoint Utility

createEndPoint(
  connectionString: String,
  securityProtocolMap: Option[Map[ListenerName, SecurityProtocol]]): EndPoint

createEndPoint…​FIXME

Note	createEndPoint is used when: CoreUtils utility is used to convert listener names to endpoints BrokerIdZNode utility is used to decode a broker metadata (from a JSON format in Zookeeper)