cluster

Type Members

1. case class Broker(id: Int, endPoints: Map[SecurityProtocol, EndPoint]) extends Product with Serializable

   

2. case class BrokerEndPoint(id: Int, host: String, port: Int) extends Product with Serializable

   

   BrokerEndpoint is used to connect to specific host:port pair.

   BrokerEndpoint is used to connect to specific host:port pair. It is typically used by clients (or brokers when connecting to other brokers) and contains no information about the security protocol used on the connection. Clients should know which security protocol to use from configuration. This allows us to keep the wire protocol with the clients unchanged where the protocol is not needed.

3. case class EndPoint(host: String, port: Int, protocolType: SecurityProtocol) extends Product with Serializable

   

   Part of the broker definition - matching host/port pair to a protocol

4. class Partition extends Logging with KafkaMetricsGroup

   

   Data structure that represents a topic partition.

   Data structure that represents a topic partition. The leader maintains the AR, ISR, CUR, RAR

5. class Replica extends Logging