Skip to content

Non-blocking retry using KafkaListener on class level #3012

@Casper-dss

Description

@Casper-dss

When using KafkaListener on class level, and configuring non blocking retry with RetryTopicConfiguration, records should go to the retry topic, when failed by exception set as non blocking exceptions.

As stated in the documentation, this functionality is not supported.
"At this time this functionality doesn’t support class level @KafkaListener annotations."

We need this functionality especially when listeners are on class level, with KafkaHandlers handling different payloads. The reason is, if one type of payload fails, we would still be able to process, the other types. Today we can either fail the message completely, or using blocking retry, which will stop processing of all types of payload.

Workaround could be having each payload on separate topics. But this breaks our topic strategy.

Metadata

Metadata

Assignees

No one assigned

    Type

    No type

    Projects

    No projects

    Milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions