ThrottledPartition

data class ThrottledPartition(val group: String, val subscription: String, val partition: Int, val limit: Int, val since: Long)

A subscription's partition throttled by backpressure: since since (epoch milliseconds), subscription of the subscription group runs at most limit handlings at once in partition.

Constructors

Link copied to clipboard
constructor(group: String, subscription: String, partition: Int, limit: Int, since: Long)

Properties

Link copied to clipboard
Link copied to clipboard
val limit: Int
Link copied to clipboard
Link copied to clipboard
val since: Long
Link copied to clipboard