http4k-connect-kafka-rest/org.http4k.connect.kafka.rest.v2.action/CommitOffsets

CommitOffsets

data class CommitOffsets(val group: ConsumerGroup, val instance: ConsumerInstance, val offsets: List<CommitOffset>) : NullableKafkaRestAction<Unit> , KafkaRestV2Action<Unit?>

Constructors

constructor(group: ConsumerGroup, instance: ConsumerInstance, offsets: List<CommitOffset>)

Properties

val group: ConsumerGroup

val instance: ConsumerInstance

val offsets: List<CommitOffset>

Functions

open override fun toRequest(): Request

open override fun toResult(response: Response): Result<Unit?, RemoteFailure>