удалённые записи, если не вычитал их.
У меня был однажды такой сценарий: настроил топик на удаление записей, если они больше суток лежат.
На неделю покасил приложение (не помню почему)
А потом запустил приложение и оно начало ругаться, что мол нет записей offset таким-то.
Я тогда просто топик пересоздал, но мне интересно, что нужно подкрутить в приложении, чтобы оно в такой ситуации начало читать самю старую запись из существующих?
https://kafka.apache.org/documentation/#auto.offset.reset
И настроить retention для offset топика чтобы было больше чем 1 день
Обсуждают сегодня