Как создать структуру в Кафке для отсрочки повторной отправки сообщения в теме

Question

Задержка создания сообщения в теме? Если нет, он скоро появится?

У меня есть тема "NQueue" для отправки различных уведомлений (Sms, Push, транзакции). Я пытаюсь вернуть сообщение с ошибкой (HttpRequest) обратно в очередь с некоторой задержкой.

Я уже перечитал всю документацию и не нашел эту функцию. Если он существует или вы знаете, как его реализовать, напишите здесь, пожалуйста.

Как:

await producer.ProduceAsync(topic, message, delay);

Ниже я приложу фото моего видения ...

Answer 1

Если вы планируете использовать Kafka Stream , я бы предложил рассмотреть вариант использования оконных агрегатов . Вкратце так:

• создать тему Кафки для сообщений об ошибках
• создать приложение Kafka Stream с оконными агрегатами , чтобы возвращать ошибочные сообщения обратно в очередь (также следует помнить о возможности подавления последовательных обновлений ). Я предполагаю, что оконные агрегаты дадут вам возможность задержать ваши сообщения с ошибками.

Если потоки вам не подходят, посмотрите Очереди недоставленных писем