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

CreateConsumer

data class CreateConsumer(val group: ConsumerGroup, val consumer: Consumer) : NonNullKafkaRestAction<NewConsumer> , KafkaRestV2Action<NewConsumer>

Constructors

constructor(group: ConsumerGroup, consumer: Consumer)

Properties

val consumer: Consumer

val group: ConsumerGroup

Functions

open override fun toRequest(): Request

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