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
KafkaConsumerfails to process aConsumerRecord.Exception thrown when an error occurs processing aConsumerRecordvia aKafkaListener.Interface thatKafkaListenerbeans can implement to handle exceptions.Helper for handling Kafka offset commit failures that can be expected during cooperative rebalancing.