vault backup: 2024-07-03 12:25:33
This commit is contained in:
parent
fbc33de081
commit
56b0ac2b58
10
.obsidian/plugins/home-tab/data.json
vendored
10
.obsidian/plugins/home-tab/data.json
vendored
@ -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": [],
|
||||
|
@ -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"
|
||||
|
@ -20,8 +20,8 @@ linked:
|
||||
- Подтверждение отправки/получения
|
||||
- Ограничение количества отправляемых сообщений
|
||||
- Управление поведением не полученных сообщений
|
||||
- [Кластеризация](Кластеризация.md)
|
||||
- [Репликация](_inbox/Репликация.md)
|
||||
- [Кластеризация](Кластеризация.md) и [Репликация](_inbox/Репликация.md) из коробки
|
||||
- Работает через push модель. Данные отправляются на producer.
|
||||
|
||||
Терминология:
|
||||
- [Queue](Queue.md) - Буфер, который хранит messages. Никакой логики.
|
||||
|
@ -23,6 +23,9 @@ Apache Kafka – это платформа потоковой передачи,
|
||||
- Хранит свои записи на диске и не использует RAM. Использует кэш диска
|
||||
- Операции считывания и записи выполняются за константное время.
|
||||
- Реализует последовательное чтение и запись на диск
|
||||
- Работает через pull модель. Consumer сам должен опрашивать кафку.
|
||||
|
||||
В отличии от [RabbitMQ](00%20RabbitMQ.md) кафка не реализует какой-то роутинг внутри. Предполагается, что за это отвечает consumer.
|
||||
|
||||
Доставка сообщений в Kafka может осуществляться как минимум тремя способами:
|
||||
- не менее одного раза (at-least-once) – сообщение будет отправляется потребителям до тех пор, пока те не подтвердят его получение;
|
||||
|
Loading…
Reference in New Issue
Block a user