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() }
Content copied to clipboard
This function acknowledges the processing of the ReceiverRecord by committing its offset.
Example usage:
val flow = kafkaReceiverFlow<String, String> { ... }
flow.collect { record -> record.acknowledge() }