проигрывать все сообщения из топика? Джоба которая каждые полчаса считывает все из топика
Взять контейнер с kafkacat и по крону обычным шельником делать, все что душе угодно
Сам шедуллер сделать через аннотацию спринга @Scheduled. Далее в классе в котором объявлен кафкаЛистенер имплементировать интерфейс ConsumerSeekAware и в методе интерфейса registerSeekCallback выполнить перемотку оффсета на начало assignments.keySet().forEach(partition -> callback.seek("events", partition.partition(), 0L. Далее по шедуллеру останавливаем контейнер (через kafka endpoint registry) и вновь стартуем его. При рестарте контейнера отработает метод registerSeekCallback
Обсуждают сегодня