Ну если сообщений не будет, вы и времени последнего не

получите. Вывод простой, сообщения либо вообще не было, либо раньше чем ретеншен. Как вам здесь дельта оффсетов поможет?

7 ответов

6 просмотров

ну сегодня создаю консюмера без группы, сгенерируется на основе uuid, резет оффсет earliest, получаю офсеты - складываю все оффсеты партиций получаю X, записываю куда нить, завтра делаю тоже самое получаю X+delta, могу судить на основании delta была ли запись за 24 часа или нет

Sergey-Rybakov Автор вопроса
Petr O.
ну сегодня создаю консюмера без группы, сгенерируе...

Понял. Пока не вижу разницы, что оффсет писать, что таймстамп, все одно через рекорд передаётся.

Sergey Rybakov
Понял. Пока не вижу разницы, что оффсет писать, чт...

сообщения а значит и таймстемпа может не быть, для получения офсетов не нужно сообщение

Sergey-Rybakov Автор вопроса
Petr O.
сообщения а значит и таймстемпа может не быть, для...

Ну в принципе да, инфо об оффсете хранит консьюмер группа. Но у вас вроде сначала вопрос стоял "когда в топик последний раз писали", а это именно про таймстамп, а не про дельту оффсетов

Sergey-Rybakov Автор вопроса
Petr O.
там приписочка - хотя бы приблизительно

Ну если у вас сообщения стёрлись, то оффсет даже приблизительно не даст вам понимания времени получения сообщения в общем случае

Petr O.
там приписочка - хотя бы приблизительно

Сделайте топик и пишите туда состояние с нужной вам частотой

Похожие вопросы

Обсуждают сегодня

А если изначально бот работал так : есть сайт онлайн школы. У каждого ученика свой кабинет. Где он авторизуется по своим данным. И уже в кабинете, на самом сайте делает оплату...
Денис 💡 Фрилансер
13
что это и почему оно? executor.start_polling(bot, skip_updates=True, on_startup=on_startup, File "/usr/local/lib/python3.10/dist-packages/aiogram/utils/executor.py", line 4...
𐌍𐌄 ᕓ𐌄𐌓𐌌Ꝋ𐌓𐌄
2
Напомните пожалуйста, v1.1 работает на PHP 8.2?
Ross
7
А что насчет FluentValidation? тоже ведь есть альтернатива у МС.
devman
13
Ребят, всем привет) Кто юзал/юзает Postgres? Я на MySQL сделал простенький сайт для диплома, но я внезапно обнаружил условие что надо было на Postgres) Проблема в том, что я н...
Dororo Steeeve
4
Спасибо. Начну с клиент-сервер. Там разберусь И еще вопрос - можно ли как то джобы отправлять на определенные клиенты? Например есть vdi и linux машина. Можно ли задачу оправ...
Sergey Ivanov
4
Всем привет! подскажите, кто-то использовал vault + гео-распределенный etcd-кластер (мемберы в разных цодах)? какие есть подводные камни? и стоит ли вообще такое делать?
Василиса Васильева
4
Читаю сейчас [нет, уже больше не читаю!] курсовую о Булгакове, написанную, похоже, с помощью ChatGPT. Это удивительный психоделический опыт. Текст в основном написан в стиле б...
✨ Uni [🌊 В отпуске]
1
Тут кто-то шарит в мед оборудовании?
Benz
10
Всем привет. Я только начал изучать nomad и есть несколько вопросов. Я хочу развернуть 1 сервер и 1 клиент чтобы потыкаться и пощупать как работает это. А можно ли развернуть...
Sergey Ivanov
2
Карта сайта