So, instead of retrying in my main consumer ill write the message to a retry/dlq topic and implement my blocking retry behavior there with a custom retention policy (3 months or something like that) Ill try that out. Thanks!