Как обеспечить соблюдение задержки между потребителями тему KAFKA (например, 5 м, 15 м, 30 м) в Spring Boot? ⇐ JAVA

[Anonymous]

Я строю механизм повторной попытки на основе Кафки в приложении Spring Boot. Настройка включает в себя: < /p>

Основная тема для нормальной обработки. < /Li>
Три темы повторных попыток (тема-ретрита-5M, тематическая-15m, тема-ретрита-30 м) для повторного разыгрывания после 5, 15 и 30 минут. /> < /ul>
Конфигурация Cafka Consumer Config используется по всем темам с использованием пружинных бобов, и я переопределяю идентификатор группы потребителей только для тем, чтобы повторно повторил. Сообщения сразу после того, как они опубликованы по темам повторения. Поскольку много сложенных сообщений убьет приложение, а также временно хранение не похоже на правильный выбор. Если сторонняя служба недоступна или отвечает, истекло, что повторно нанести услугу мгновенно не будет стоить этого, мы хотим иметь механизм повторной попытки после некоторой задержки. У нас есть одна услуга, которая выполняет нашу фактическую работу и публикует информацию в очередь Кафки и службу абонента третьих сторон, которая потребляет из очереди, готовит запрос и совершает третье лицо.

Подробнее здесь: https://stackoverflow.com/questions/797 ... 15m-30m-in