connector-apache-kafka/com.river.connector.apache.kafka

Package-level declarations

Types

class MutableReceiverOptions<K, V>(props: Map<String, Any> = mutableMapOf())

class MutableSenderOptions<K, V>(props: Map<String, Any> = mutableMapOf())

fun ReceiverRecord<*, *>.acknowledge()

This function acknowledges the processing of the ReceiverRecord by committing its offset.

suspend fun ReceiverOffset.coCommit()

This function commits the ReceiverOffset suspending the coroutine until the commit operation is complete.

suspend fun ReceiverRecord<*, *>.coCommit()

This function commits the ReceiverOffset of the ReceiverRecord suspending the coroutine until the commit operation is complete.

fun <K, V> kafkaReceiver(options: MutableReceiverOptions<K, V>.() -> Unit): KafkaReceiver<K, V>

This function creates a KafkaReceiver using provided receiver options.

fun <K, V> kafkaReceiverFlow(options: MutableReceiverOptions<K, V>.() -> Unit): Flow<ReceiverRecord<K, V>>

This function creates a KafkaReceiver and converts it into a Flow using provided options.

fun <K, V> kafkaSender(options: MutableSenderOptions<K, V>.() -> Unit): KafkaSender<K, V>

This function creates a KafkaSender using provided sender options.

fun <K, V, T> CoroutineScope.kafkaSenderChannel(options: MutableSenderOptions<K, V>.() -> Unit): Channel<SenderRecord<K, V, T>>

This function creates a Channel for SenderRecord in the CoroutineScope using provided options.

fun <K, V> KafkaReceiver<K, V>.receiveAsFlow(): Flow<ReceiverRecord<K, V>>

This function is an extension function for KafkaReceiver that returns a Flow of ReceiverRecords.

fun <K, V> receiverOptions(options: MutableReceiverOptions<K, V>.() -> Unit): ReceiverOptions<K, V>

This function provides ReceiverOptions using provided options.

fun <K, V, T> KafkaSender<K, V>.send(upstream: Flow<SenderRecord<K, V, T>>): Flow<SenderResult<T>>

This function sends records upstream as a Flow using the KafkaSender.

fun <K, V> senderOptions(options: MutableSenderOptions<K, V>.() -> Unit): SenderOptions<K, V>

This function creates SenderOptions using the provided configuration block.