http4k-connect-kafka-rest-fake/org.http4k.connect.kafka.rest.model/TopicOffsetState

TopicOffsetState

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

Constructors

TopicOffsetState

constructor(next: Offset = Offset.ZERO, committed: Offset? = null)

Properties

val committed: Offset?

val next: Offset

Functions

fun commitAt(lastOffset: Offset): TopicOffsetState

fun next(nextOffset: Offset): TopicOffsetState