kafka

cluster

package cluster

Visibility
  1. Public
  2. All

Type Members

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

  2. class Partition extends Logging with KafkaMetricsGroup

    Data structure that represents a topic partition.

  3. class Replica extends Logging

Value Members

  1. object Broker extends Serializable

    A Kafka broker

Ungrouped