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

ConsumeRecords

data class ConsumeRecords(val group: ConsumerGroup, val instance: ConsumerInstance, val format: RecordFormat, val timeout: Duration? = null) : NullableKafkaRestAction<Array<TopicRecord>> , KafkaRestV2Action<Array<TopicRecord>?> (source)

Constructors

constructor(group: ConsumerGroup, instance: ConsumerInstance, format: RecordFormat, timeout: Duration? = null)

Properties

val format: RecordFormat

val group: ConsumerGroup

val instance: ConsumerInstance

val timeout: Duration?

Functions

open override fun toRequest(): Request

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