Package io.micronaut.configuration.kafka.config

Interface DefaultKafkaListenerExceptionHandlerConfiguration

All Superinterfaces:

io.micronaut.core.util.Toggleable

All Known Implementing Classes:

DefaultKafkaListenerExceptionHandlerConfigurationProperties

public interface DefaultKafkaListenerExceptionHandlerConfiguration
extends io.micronaut.core.util.Toggleable

Default Kafka listener exception handler configuration.

Since:

5.1.0

Method Summary

Modifier and Type	Method	Description
boolean	isCommitRecordOnDeserializationFailure()
boolean	isSkipRecordOnDeserializationFailure()

Methods inherited from interface io.micronaut.core.util.Toggleable

isEnabled

Method Details

isSkipRecordOnDeserializationFailure

boolean isSkipRecordOnDeserializationFailure()

Returns:

Whether to skip record on deserialization failure.

isCommitRecordOnDeserializationFailure

boolean isCommitRecordOnDeserializationFailure()

Returns:

Whether to commit record on deserialization failure.