Functions

Link copied to clipboard
abstract fun handle(failure: KafkaRecordDecodeFailure): Mono<Void>

Handles a record that cannot be decoded or violates transport invariants.