получите. Вывод простой, сообщения либо вообще не было, либо раньше чем ретеншен. Как вам здесь дельта оффсетов поможет?
ну сегодня создаю консюмера без группы, сгенерируется на основе uuid, резет оффсет earliest, получаю офсеты - складываю все оффсеты партиций получаю X, записываю куда нить, завтра делаю тоже самое получаю X+delta, могу судить на основании delta была ли запись за 24 часа или нет
Понял. Пока не вижу разницы, что оффсет писать, что таймстамп, все одно через рекорд передаётся.
сообщения а значит и таймстемпа может не быть, для получения офсетов не нужно сообщение
Ну в принципе да, инфо об оффсете хранит консьюмер группа. Но у вас вроде сначала вопрос стоял "когда в топик последний раз писали", а это именно про таймстамп, а не про дельту оффсетов
там приписочка - хотя бы приблизительно
Ну если у вас сообщения стёрлись, то оффсет даже приблизительно не даст вам понимания времени получения сообщения в общем случае
Сделайте топик и пишите туда состояние с нужной вам частотой
Обсуждают сегодня