http4k-connect-kafka-rest/org.http4k.connect.kafka.rest.v3.action/ProduceRecords

ProduceRecords

data class ProduceRecords(val id: ClusterId, val topic: Topic, val records: List<Record>) : NullableKafkaRestAction<Array<ProducedRecord>> , KafkaRestV3Action<Array<ProducedRecord>?>

Constructors

constructor(id: ClusterId, topic: Topic, records: List<Record>)

Properties

val id: ClusterId

val records: List<Record>

val topic: Topic

Functions

open override fun toRequest(): Request

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