I need to endlessly retry any exception that might happen during consuming retry topic (even like deserialization errors, as in our case it might be due to temporary issues with schema registry) up until it successfully be handled, accepting the fact that specific partition will be blocked till the message will be processed. Messages are consumed in the following way: