Надёжность доставки в Kafka обеспечивается за счёт репликации данных между узлами кластера Для этого применяется механизм ISR (in-sync replicas): запись подтверждают только реплики, которые синхронизированы с лидером…
Гарантии доставки сообщений в RabbitMQ в асинхронной модели RabbitMQ представляет собой брокер сообщений, поддерживающий надежную доставку Применяются гарантии at-most-once, at-least-once и условно exactly-once Для…
персистентность — это гарантия сохранения данных на диске предусмотрено два основных механизма: RDB (Snapshotting): через заданные интервалы создаёт моментальные снимки состояния памяти и сохраняет их в компактные…
Kafka и RabbitMQ: модели доставки push и pull Kafka использует pull-модель Воркер самостоятельно запрашивает появившиеся сообщения Это позволяет управлять темпом чтения: consumer контролирует offset Такой подход…
Что представляет собой паттерн Singleton? Это паттерн проектирования, относящийся к группе порождающих Он гарантирует наличие единственного экземпляра класса в приложении И предоставляет глобальную точку доступа к…
Обмен данными выполняется по асинхронному протоколу Для передачи используются очереди (queue) либо топики (publish-subscribe) Микросервисы отправляют сообщения в брокер и подписываются на нужные события Поддерживаются…
Как исключение в одной задаче может повлиять на выполнение других? — Конкурентность и асинхронность — Как правило, исключение ограничено одной задачей — Без обработки задача завершается и не продолжает выполнение —…
распределённая публично-подписная система потоковой обработки событий (event streaming) масштабирование выполняется за счёт партиционирования топиков каждый топик разделён на партиции, что обеспечивает параллельную…
Apache Kafka представляет собой распределённую платформу для обмена сообщениями и асинхронного взаимодействия сервисов Производитель (producer) публикует сообщения в тематические очереди, которые называются топиками…
Как сохранить в Kafka только последнее событие пользователя? использовать ключи сообщений (key) — в качестве ключа передавать идентификатор пользователя включить для топика compaction — Kafka сохранит только последнее…
Exactly-once обработка в Kafka: как реализовать и что учесть Тема: обработка сообщений, Kafka, идемпотентность В основе exactly-once находится транзакционная запись в Kafka через Transaction API Применяется…
RabbitMQ — брокер сообщений, поддерживающий подтверждения (ACK) Настроить у потребителя ручные подтверждения (manual ACK) Если потребитель завершился до отправки ACK, сообщение сохраняется в очереди и передается…