офсет при использовании spring + kafkalistener, при перезагрузке pod’a? Оно например упало, заново поднялось и прочитало последнее сообщение из топика, даже если уже читало. Играю с офсет ресетами, но пока не помогает
Если сообщение уже обработалось, а потом кафка опять его повторно отправляет - значит коммит оффсета в первый раз не случился. At least once семантика доставки
а когда кафка его отправляет 1 раз в сутки, но при этом под падает пару раз за сутки скажем, и ему нужно после каждого рестарта эту единственную запись последнюю вычитать из топика, как быть?
не делать коммит до того как сообщение будет обработано
Проверьте время хранения оффсетов на кафке, по умолчанию раньше были сутки и возможны тогда сбросы
Обсуждают сегодня