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

Question

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

должны иметь функции

• сообщения в очереди должны быть стойкими. (только до тех пор, пока они не будут успешно обработаны потребителями.)
• Сообщения в очередях должны удаляться только тогда, когда потребители, входящие в систему, смогли успешно обработать сообщение. В принципе, потребитель должен ACK. что он обработал сообщение успешно.

Хорошо иметь функции

• Чтобы увеличить пропускную способность, потребители должны быть в состоянии вытащить пакет сообщений из очереди.

Answer 1

Если вы собираетесь с Kafka он будет сохраняет сообщение только в течение настраиваемого периода времени, после которого сообщения будут отброшены, чтобы освободить пространство независимо от того, потребляются или нет.

И это просто обязанность потребителей Kafka отслеживать то, что было израсходовано.

ИМХО, если вам требуется сохранить сообщения навсегда, чем использовать другой носитель данных (база данных может быть).