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

ConsumerState

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

Constructors

constructor(instances: Set<ConsumerInstance>, autoCommit: Boolean, offsets: Map<Topic, TopicOffsetState>)

Properties

val autoCommit: Boolean

val instances: Set<ConsumerInstance>

val offsets: Map<Topic, TopicOffsetState>

Functions

fun add(instance: ConsumerInstance): ConsumerState

fun commitAt(topic: Topic, lastOffset: Offset): ConsumerState

committedRecords

fun committedRecords(topic: Topic): Int

fun new(topic: Topic): ConsumerState

fun next(topic: Topic, nextOffset: Offset): ConsumerState

fun remove(instance: ConsumerInstance): ConsumerState