acknowledge

fun ReceiverRecord<*, *>.acknowledge()

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

Example usage:

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

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