Class DefaultKafkaListenerExceptionHandlerConfigurationProperties
java.lang.Object
io.micronaut.configuration.kafka.config.DefaultKafkaListenerExceptionHandlerConfigurationProperties
- All Implemented Interfaces:
DefaultKafkaListenerExceptionHandlerConfiguration
,io.micronaut.core.util.Toggleable
@ConfigurationProperties("kafka.default-listener-exception-handler")
public class DefaultKafkaListenerExceptionHandlerConfigurationProperties
extends Object
implements DefaultKafkaListenerExceptionHandlerConfiguration
ConfigurationProperties
implementation of DefaultKafkaListenerExceptionHandlerConfiguration
.- Since:
- 5.1.0
-
Field Summary
FieldsModifier and TypeFieldDescriptionstatic final boolean
The default value forcommitRecordOnDeserializationFailure
.static final boolean
The default value forskipRecordOnDeserializationFailure
.static final String
The default prefix used for the default Kafka listener exception handler configuration. -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionboolean
boolean
void
setCommitRecordOnDeserializationFailure
(boolean commitRecordOnDeserializationFailure) Whether to commit record on deserialization failure.void
setSkipRecordOnDeserializationFailure
(boolean skipRecordOnDeserializationFailure) Whether to skip record on deserialization failure.Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface io.micronaut.core.util.Toggleable
isEnabled
-
Field Details
-
PREFIX
The default prefix used for the default Kafka listener exception handler configuration.- See Also:
-
DEFAULT_SKIP_RECORD_ON_DESERIALIZATION_FAILURE
public static final boolean DEFAULT_SKIP_RECORD_ON_DESERIALIZATION_FAILUREThe default value forskipRecordOnDeserializationFailure
.- See Also:
-
DEFAULT_COMMIT_RECORD_ON_DESERIALIZATION_FAILURE
public static final boolean DEFAULT_COMMIT_RECORD_ON_DESERIALIZATION_FAILUREThe default value forcommitRecordOnDeserializationFailure
.- See Also:
-
-
Constructor Details
-
DefaultKafkaListenerExceptionHandlerConfigurationProperties
public DefaultKafkaListenerExceptionHandlerConfigurationProperties()
-
-
Method Details
-
isSkipRecordOnDeserializationFailure
public boolean isSkipRecordOnDeserializationFailure()- Specified by:
isSkipRecordOnDeserializationFailure
in interfaceDefaultKafkaListenerExceptionHandlerConfiguration
- Returns:
- Whether to skip record on deserialization failure.
-
setSkipRecordOnDeserializationFailure
public void setSkipRecordOnDeserializationFailure(boolean skipRecordOnDeserializationFailure) Whether to skip record on deserialization failure. Default value true- Parameters:
skipRecordOnDeserializationFailure
- Whether to skip record on deserialization failure.
-
isCommitRecordOnDeserializationFailure
public boolean isCommitRecordOnDeserializationFailure()- Specified by:
isCommitRecordOnDeserializationFailure
in interfaceDefaultKafkaListenerExceptionHandlerConfiguration
- Returns:
- Whether to commit record on deserialization failure.
-
setCommitRecordOnDeserializationFailure
public void setCommitRecordOnDeserializationFailure(boolean commitRecordOnDeserializationFailure) Whether to commit record on deserialization failure. Default value false- Parameters:
commitRecordOnDeserializationFailure
- Whether to commit record on deserialization failure.
-