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

send

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.

Return

a Flow of SendResult.

Example usage:

val sender: KafkaSender<String, String> = ...
val upstream: Flow<SenderRecord<String, String, Unit>> = ...
val resultFlow: Flow<SendResult<String, String>> = sender.send(upstream)
Content copied to clipboard

Parameters

upstream

The Flow of SenderRecord to be sent.