apache kafka, как отследить/детекитровать событие - необработанные консюмером сообщения удалены retention политикой

Бывают случаи, когда консюмер по каким-то причинам не обработал сообщения, а retention политика уже эти сообщения удалила, и хотелось бы реагировать на это событие, например переотправить сообщения.

Собственно вопрос, как отследить/детекитровать событие "необработанные консюмером сообщения удалены ретеншен политикой" ? Далее по тексту это событие буду называть Событие X.

Из того что я тестировал, если необработанные сообщения удаляет ретеншен политика, то на консюмере с настройкой AUTO_OFFSET_RESET_CONFIG= "none" происходит эксепшен org.apache.kafka.clients.consumer.OffsetOutOfRangeException. Можно ли на этот exception закладываться, как на Событие Х, или этот exception может кидаться в других случаях ? Может быть есть другой способ отследить Событие Х ?


Ответы (0 шт):