Очереди и стриминг: RabbitMQ, Kafka

Отправить письмо, сгенерить отчёт, синхронизировать сервис — не нужно ждать прямо в запросе. Очередь делает работу асинхронной и переживает отказы отдельных узлов.

Как устроена очередь

// Производитель кладёт сообщение в обменник
channel.publish(exchange, "order.created", msg);

// Потребитель слушает и подтверждает обработку
consumer.onMessage(async (msg) => {
  try { await sendEmail(msg); channel.ack(msg); }
  catch (err) { channel.nack(msg); } // ретрай позже
});

RabbitMQ vs Kafka

• RabbitMQ — умная маршрутизация, точная доставка, хорош для задач сверх-по-одному (письма, генерация);
• Kafka — таблица-лог событий: replay, высокая пропускная способность, метрики и «история изменений».