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

ConsumeRecords

data class ConsumeRecords(val format: RecordFormat, val timeout: Duration? = null) : NonNullKafkaRestAction<Array<TopicRecord>> , KafkaRestConsumerAction<Array<TopicRecord>>

Constructors

Link copied to clipboard
constructor(format: RecordFormat, timeout: Duration? = null)

Properties

Link copied to clipboard
Link copied to clipboard
val timeout: Duration? = null

Functions

Link copied to clipboard
open override fun toRequest(): Request
Link copied to clipboard
open override fun toResult(response: Response): Result<Array<TopicRecord>, RemoteFailure>