http4k-connect-kafka-rest/org.http4k.connect.kafka.rest.v2.model/Consumer

Consumer

@JsonSerializable

data class Consumer(val name: ConsumerInstance, val format: RecordFormat, @Json(name = "auto.offset.reset") val reset: AutoOffsetReset = latest, @Json(name = "auto.commit.enable") val enableAutocommit: AutoCommitEnable = `true`, @Json(name = "fetch.min.bytes") val minBytes: String? = null, @Json(name = "consumer.request.timeout.ms") val timeout: ConsumerRequestTimeout? = null)

Constructors

Consumer

constructor(name: ConsumerInstance, format: RecordFormat, @Json(name = "auto.offset.reset") reset: AutoOffsetReset = latest, @Json(name = "auto.commit.enable") enableAutocommit: AutoCommitEnable = `true`, @Json(name = "fetch.min.bytes") minBytes: String? = null, @Json(name = "consumer.request.timeout.ms") timeout: ConsumerRequestTimeout? = null)

Properties

enableAutocommit

val enableAutocommit: AutoCommitEnable

format

val format: RecordFormat

minBytes

val minBytes: String? = null

name

val name: ConsumerInstance

reset

val reset: AutoOffsetReset

timeout

val timeout: ConsumerRequestTimeout? = null