package data
Ordering
- Alphabetic
Visibility
- Public
- All
Type Members
- case class CommittedStatus(topic: String, subscribed: Boolean, partitionStats: List[AssignedPartition], partitionOffsetState: PartitionOffsetState) extends Product with Serializable
- case class KafkaNode(id: Int, host: String, port: Int, rack: String) extends Product with Serializable
- case class KafkaPartitionInfo(topic: String, partition: Int, leader: KafkaNode, replicas: List[KafkaNode], inSyncReplicas: List[KafkaNode], offlineReplicas: List[KafkaNode]) extends Product with Serializable
- final case class PartitionOffsetState(offsetByPartitionByTopic: Map[String, Map[Int, Long]] = Map.empty) extends Product with Serializable
an immutable means of tracking which offset/partitions have been observed
Value Members
- object CommittedStatus extends Serializable
- object KafkaNode extends Serializable
- object KafkaPartitionInfo extends Serializable
- object PartitionOffsetState extends Serializable