KafkaRecoverableExceptionProvider

Registers Kafka's RetriableException (and so each subclass: timeouts, leader changes, unavailable brokers and coordinators, ...) as RecoverableType.RECOVERABLE, so the framework's retries (RetryableFilter, the event-store append resolution) retry a send that failed on a transient broker condition.

Constructors

Link copied to clipboard
constructor()

Functions

Link copied to clipboard
open override fun register(registrar: RecoverableExceptionRegistrar)