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
Ungrouped