diff --git a/.obsidian/plugins/home-tab/data.json b/.obsidian/plugins/home-tab/data.json index c9456f9a..90f78fba 100644 --- a/.obsidian/plugins/home-tab/data.json +++ b/.obsidian/plugins/home-tab/data.json @@ -25,7 +25,11 @@ "recentFilesStore": [ { "filepath": "_inbox/Kafka.md", - "timestamp": 1719998004180 + "timestamp": 1719998664626 + }, + { + "filepath": "_inbox/00 RabbitMQ.md", + "timestamp": 1719998632586 }, { "filepath": "_inbox/Отставание реплики в БД.md", @@ -38,10 +42,6 @@ { "filepath": "_inbox/Репликация в PostgreSQL.md", "timestamp": 1719997807888 - }, - { - "filepath": "_inbox/Брокер сообщений.md", - "timestamp": 1719997469923 } ], "bookmarkedFileStore": [], diff --git a/.obsidian/plugins/recent-files-obsidian/data.json b/.obsidian/plugins/recent-files-obsidian/data.json index f304fcca..ce1bf89a 100644 --- a/.obsidian/plugins/recent-files-obsidian/data.json +++ b/.obsidian/plugins/recent-files-obsidian/data.json @@ -4,6 +4,10 @@ "basename": "Kafka", "path": "_inbox/Kafka.md" }, + { + "basename": "00 RabbitMQ", + "path": "_inbox/00 RabbitMQ.md" + }, { "basename": "Отставание реплики в БД", "path": "_inbox/Отставание реплики в БД.md" @@ -20,10 +24,6 @@ "basename": "Брокер сообщений", "path": "_inbox/Брокер сообщений.md" }, - { - "basename": "00 RabbitMQ", - "path": "_inbox/00 RabbitMQ.md" - }, { "basename": "00 Nginx", "path": "wiki/zero/00 Nginx.md" diff --git a/_inbox/00 RabbitMQ.md b/_inbox/00 RabbitMQ.md index b7920344..493db283 100644 --- a/_inbox/00 RabbitMQ.md +++ b/_inbox/00 RabbitMQ.md @@ -20,8 +20,8 @@ linked: - Подтверждение отправки/получения - Ограничение количества отправляемых сообщений - Управление поведением не полученных сообщений -- [Кластеризация](Кластеризация.md) -- [Репликация](_inbox/Репликация.md) +- [Кластеризация](Кластеризация.md) и [Репликация](_inbox/Репликация.md) из коробки +- Работает через push модель. Данные отправляются на producer. Терминология: - [Queue](Queue.md) - Буфер, который хранит messages. Никакой логики. diff --git a/_inbox/Kafka.md b/_inbox/Kafka.md index a6f20384..b317c5da 100644 --- a/_inbox/Kafka.md +++ b/_inbox/Kafka.md @@ -23,6 +23,9 @@ Apache Kafka – это платформа потоковой передачи, - Хранит свои записи на диске и не использует RAM. Использует кэш диска - Операции считывания и записи выполняются за константное время. - Реализует последовательное чтение и запись на диск +- Работает через pull модель. Consumer сам должен опрашивать кафку. + +В отличии от [RabbitMQ](00%20RabbitMQ.md) кафка не реализует какой-то роутинг внутри. Предполагается, что за это отвечает consumer. Доставка сообщений в Kafka может осуществляться как минимум тремя способами: - не менее одного раза (at-least-once) – сообщение будет отправляется потребителям до тех пор, пока те не подтвердят его получение;