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

GetOffsets

data class GetOffsets(val group: ConsumerGroup, val instance: ConsumerInstance, val partitions: List<PartitionOffsetRequest>) : NullableKafkaRestAction<CommitOffsetsSet> , KafkaRestV2Action<CommitOffsetsSet?>

Constructors

constructor(group: ConsumerGroup, instance: ConsumerInstance, partitions: List<PartitionOffsetRequest>)

Properties

val group: ConsumerGroup

val instance: ConsumerInstance

val partitions: List<PartitionOffsetRequest>

Functions

open override fun toRequest(): Request

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