receiveAsFlow

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.

a Flow of ReceiverRecord.

Example usage:

val kafkaReceiver: KafkaReceiver<String, String> = ...

val flow: Flow<ReceiverRecord<String, String>> = kafkaReceiver.receiveAsFlow()