Package io.micronaut.configuration.kafka.exceptions
package io.micronaut.configuration.kafka.exceptions
Kafka specific exceptions.
- Since:
- 1.0
- Author:
- graemerocher
-
ClassDescriptionThe default ExceptionHandler used when a
KafkaConsumer
fails to process aConsumerRecord
.Exception thrown when an error occurs processing aConsumerRecord
via aKafkaListener
.Interface thatKafkaListener
beans can implement to handle exceptions.