Skip to content

Add ConversionException in FailedRecordProcessor.classifier to skip retrying #1566

@bananayong

Description

@bananayong

Affects Version(s): 2.5.4

Hi, I would like to request a convenience feature.
I am writing a kafka listener which need json deserialization.
I learned that spring-kafka support JsonDeserializer and JsonMessageConverter.
And, I did choose JsonMessageConverter because it's more flexible.

The problem is when using JsonMessageConverter, if deserialization fails, it keeps to retry because ConversionExceptionis not in exception classifications of FailedRecordProcessor
I solved this issue through errorHandler.addNotRetryableException(ConversionException.class)
But, It will be nice if ConversionException is in exception classifications by default

Please, Consider to add ConversionException in exception classifications

Thank you!

Metadata

Metadata

Type

No type

Projects

No projects

Milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions