TopicOffsetState

data class TopicOffsetState(val next: Offset = Offset.ZERO, val committed: Offset? = null)

Constructors

Link copied to clipboard
constructor(next: Offset = Offset.ZERO, committed: Offset? = null)

Properties

Link copied to clipboard
val committed: Offset? = null
Link copied to clipboard

Functions

Link copied to clipboard
fun commitAt(lastOffset: Offset): TopicOffsetState
Link copied to clipboard
fun next(nextOffset: Offset): TopicOffsetState