wow-kafka/me.ahoo.wow.kafka/AcknowledgeKafkaRecordDecodeFailureHandler

AcknowledgeKafkaRecordDecodeFailureHandler

object AcknowledgeKafkaRecordDecodeFailureHandler : KafkaRecordDecodeFailureHandler

Functions

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

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

Generated by Dokka
© 2026 Copyright