Package io.micronaut.configuration.kafka.config

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

Fields

Modifier and Type	Field	Description
static final boolean	DEFAULT_COMMIT_RECORD_ON_DESERIALIZATION_FAILURE	The default value for commitRecordOnDeserializationFailure.
static final boolean	DEFAULT_SKIP_RECORD_ON_DESERIALIZATION_FAILURE	The default value for skipRecordOnDeserializationFailure.
static final String	PREFIX	The default prefix used for the default Kafka listener exception handler configuration.

Constructor Summary

Constructors

Constructor	Description
DefaultKafkaListenerExceptionHandlerConfigurationProperties()

Method Summary

Modifier and Type	Method	Description
boolean	isCommitRecordOnDeserializationFailure()
boolean	isSkipRecordOnDeserializationFailure()
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

public static final String PREFIX

The default prefix used for the default Kafka listener exception handler configuration.

See Also:

• Constant Field Values

DEFAULT_SKIP_RECORD_ON_DESERIALIZATION_FAILURE

public static final boolean DEFAULT_SKIP_RECORD_ON_DESERIALIZATION_FAILURE

The default value for skipRecordOnDeserializationFailure.

See Also:

• Constant Field Values

DEFAULT_COMMIT_RECORD_ON_DESERIALIZATION_FAILURE

public static final boolean DEFAULT_COMMIT_RECORD_ON_DESERIALIZATION_FAILURE

The default value for commitRecordOnDeserializationFailure.

See Also:

• Constant Field Values

Constructor Details

DefaultKafkaListenerExceptionHandlerConfigurationProperties

public DefaultKafkaListenerExceptionHandlerConfigurationProperties()

Method Details

isSkipRecordOnDeserializationFailure

public boolean isSkipRecordOnDeserializationFailure()

Specified by:

isSkipRecordOnDeserializationFailure in interface DefaultKafkaListenerExceptionHandlerConfiguration

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 interface DefaultKafkaListenerExceptionHandlerConfiguration

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.