У меня есть служба, которая использует потоки кафки и имеет локальный магазин кафки. Я храню записи (события) Кафки с отметкой времени в этом хранилище, а затем имею пунктуатор, который перебирает хранилище Кафки каждые полчаса. Если текущее значение метки времени больше значения метки времени события в хранилище kafka, я удаляю это событие из хранилища kafka и выводю его в тему.
Я бы хотел изменить этот подход, поскольку вместовыполняя эту итерацию через магазин kafka через регулярные промежутки времени, я хочу, чтобы он всегда делал это в четверть текущего или четверть следующего часа. Пример. Итерируйте только через магазин Кафки и создавайте подходящие события в 12:15, 12:45, 1:15, 1:45, .... и так далее. Как мне это сделать? Есть ли у Кафки нечто похожее на пунктуатор, который мы можем настроить для проверки в определенное время, а не через определенные интервалы?