coCommit

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

Example usage:

val flow = kafkaReceiverFlow<String, String> { ... }

flow.collect { record -> record.receiverOffset().acknowledge() }

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

Example usage:

val flow = kafkaReceiverFlow<String, String> { ... }

flow.collect { record -> record.coCommit() }