http4k-connect-kafka-rest/org.http4k.connect.kafka.rest/KafkaRest

KafkaRest

interface KafkaRest

Docs: https://docs.confluent.io/platform/current/kafka-rest/

Types

object Companion

Functions

consumeAndCommitRecords

inline fun <T : Any> KafkaRest.consumeAndCommitRecords(group: ConsumerGroup, consumerInstance: ConsumerInstance, topic: Topic, recordFormat: RecordFormat, recordConsumer: RecordConsumer<T>): Result<List<Unit?>?, Any>

Process Records on a Topic using the passed RecordConsumer, and either commits the Offset after processing each.

abstract operator fun <R> invoke(action: KafkaRestV2Action<R>): Result<R, RemoteFailure>

abstract operator fun <R> invoke(action: KafkaRestV3Action<R>): Result<R, RemoteFailure>

produceMessagesWithPartitions

fun KafkaRest.produceMessagesWithPartitions(topic: Topic, records: Records, fn: (List<PartitionId>) -> Partitioner<Any?, Any?>): Result<ProducedMessages?, RemoteFailure>

Rewrites the partitions of messages using the passed Partitioner, after getting the list of partitions to write to

produceRecordsWithPartitions

fun KafkaRest.produceRecordsWithPartitions(topic: Topic, clusterId: ClusterId, records: List<Record>, fn: (List<PartitionId>) -> Partitioner<Any?, Any?>): Result<Array<ProducedRecord>?, RemoteFailure>

Rewrites the partitions of records using the passed Partitioner, after getting the list of partitions to write to