PartitionView
data class PartitionView(val partition: Int, val position: Long, val runs: Boolean = false, val head: Long? = null, val paused: PausedPartition? = null, val throttled: ThrottledPartition? = null)
Where a subscription stands in partition: every entry up to position is complete. In a partition this node runs, position is its live watermark, head the head the last sample read (null when it read none), and the partition may be paused on a systemic failure or throttled by backpressure; in another, position is its saved checkpoint, which the node that runs it moves.
Constructors
Link copied to clipboard
constructor(partition: Int, position: Long, runs: Boolean = false, head: Long? = null, paused: PausedPartition? = null, throttled: ThrottledPartition? = null)