kafka

cluster

package cluster

Visibility
  1. Public
  2. All

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.

  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.

  5. class Replica extends Logging

Value Members

  1. object Broker extends Serializable

    A Kafka broker.

  2. object BrokerEndPoint extends Serializable

  3. object EndPoint extends Serializable

Ungrouped