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

Package-level declarations

Types

data class ConsumerState(val instances: Set<ConsumerInstance>, val autoCommit: Boolean, val offsets: Map<Topic, TopicOffsetState>)

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

operator fun Offset.dec(): Offset

operator fun Offset.inc(): Offset

operator fun Offset.minus(that: Offset): Offset

operator fun Offset.plus(that: Offset): Offset