handle

open override fun handle(failure: KafkaRecordDecodeFailure): Mono<Void>

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

Completing the returned Mono authorizes the bus to acknowledge and skip the record. Emitting an error leaves the record unacknowledged and terminates the receive stream.