-
Notifications
You must be signed in to change notification settings - Fork 1.7k
Description
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.