kafka
cluster
package
cluster
Visibility
Public
All
Type Members
case class
Broker
(
id: Int
,
host: String
,
port: Int
)
extends Product with Serializable
class
Partition
extends Logging with KafkaMetricsGroup
Data structure that represents a topic partition.
class
Replica
extends Logging
Value Members
object
Broker
extends Serializable
A Kafka broker