Broker

Broker is a data structure that represents a Kafka broker using the following properties:

Broker is created when:

KafkaServer is requested to createBrokerInfo
MetadataCache is requested to update the metadata
BrokerIdZNode utility is used to decode a broker metadata (from JSON format in Zookeeper)

node(
  listenerName: ListenerName): Node

node looks up the node by the ListenerName.

node throws an BrokerEndPointNotAvailableException when the ListenerName could not be found:

End point with listener name [listenerName] not found for broker [id]

Note	`node` is used when: `ControllerChannelManager` is requested to register a new broker `AbstractControllerBrokerRequestBatch` is requested to send LeaderAndIsr and UpdateMetadata requests out to all brokers `KafkaServer` is requested to shut down (and controlledShutdown)

getNode(
  listenerName: ListenerName): Option[Node]

getNode returns the Node for the ListenerName if available in the endPointsMap internal registry. Otherwise, getNode returns None.

Note	`getNode` is used when: `Broker` is requested for the Node for a given ListenerName `KafkaApis` is requested to handle a Metadata request `MetadataCache` is requested to getPartitionReplicaEndpoints

toServerInfo(
  clusterId: String,
  config: KafkaConfig): AuthorizerServerInfo

toServerInfo…FIXME

Note	`toServerInfo` is used when `KafkaServer` is requested to start up (and start an Authorizer if configured).

Provide feedback