Package-level declarations
Functions
Link copied to clipboard
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.
Link copied to clipboard
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