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

[Anonymous]

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

[*] Основная тема для нормальной обработки. < /Li>
Три темы повторения (

Код: Выделить всё

topic-retry-5m

, тема-ретрита-15m , тема-ретрита-30 м ) для повторного повторного неудачного события после 5 , 15 и 30 минуты.
Каждая тема рита имеет свою собственную @kafkalistener . Использование весенних бобов, и я переопределяю идентификатор группы потребителей только для тем, чтобы повторно повторно. Темы. Поскольку много сложенных сообщений убьет приложение, а также временно хранение не похоже на правильный выбор. Если сторонняя служба недоступна или отвечает, истекло, что повторно нанести услугу мгновенно не будет стоить этого, мы хотим иметь механизм повторной попытки после некоторой задержки. У нас есть одна услуга, которая выполняет нашу фактическую работу и публикует информацию в очередь Кафки и сторонний сервис абонента, который потребляет в очереди, готовит запрос и совершает третье лицо.

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